tapr.proto

// Copyright 2018 Klaus Birkelund Abildgaard Jensen
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.

syntax = "proto3";

package proto;

message StatRequest {
	string name = 1;
}

message StatResponse {
	int64 size = 1;
}

message PushPrepareRequest {
	string name = 1;
	int64 offset = 2;
	bool append = 3;

	bool dataset = 4;
}

message PushPrepareResponse {
	bytes tx = 1;
	bytes error = 2;
}

// PushRequest is sent as the first message to the push endpoint, followed
// by a stream of Chunk messages.
message PushRequest {
	bytes tx = 1;
}

message PushResponse {
	bytes error = 1;
}

message PushLogRequest {
	bytes tx = 1;
}

message PushLogEntry {
	int64 seq = 1;
	bytes error = 2;
}

message PullPrepareRequest {
	string name = 1;
	int64 offset = 2;
}

message PullPrepareResponse {
	bytes tx = 1;
	bytes error = 2;
}

message PullRequest {
	bytes tx = 1;
}

message Chunk {
	// name of the data contained in the chunk
	string name = 1;

	// contained data
	bytes data = 2;

	// error (used only in pull)
	bytes error = 3;
}

message Vector {
	bool split = 1;
	repeated string names = 2;
	repeated bytes values = 3;
}

enum LogLevel {
	Debug = 0;
	Info = 1;
	Warning = 2;
	Error = 3;
	Disabled = 4;
}

message LogTailRequest {
	LogLevel level = 1;
}

message LogEvent {
	LogLevel level = 1;
	string message = 2;
}