proto

package
v0.0.0-...-c8a5df3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 11, 2018 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files: 

tapr.proto

It has these top-level messages: 

StatRequest
StatResponse
PushPrepareRequest
PushPrepareResponse
PushRequest
PushResponse
PushLogRequest
PushLogEntry
PullPrepareRequest
PullPrepareResponse
PullRequest
Chunk
Vector
LogTailRequest
LogEvent

Index

Constants

This section is empty.

Variables

View Source 
var LogLevel_name = map[int32]string{
	0: "Debug",
	1: "Info",
	2: "Warning",
	3: "Error",
	4: "Disabled",
}
View Source 
var LogLevel_value = map[string]int32{
	"Debug":    0,
	"Info":     1,
	"Warning":  2,
	"Error":    3,
	"Disabled": 4,
}

Functions

func TaprLogEvent 

func TaprLogEvent(pb *LogEvent) *log.Event

TaprLogEvent converts a proto.LogEvent to a log.Event.

func TaprLogLevel 

func TaprLogLevel(pb LogLevel) log.Level

TaprLogLevel converts a proto.Loglevel to a log.Level.

Types

type Chunk 

type Chunk struct {
	// name of the data contained in the chunk
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// contained data
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// error (used only in pull)
	Error []byte `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
}

func (*Chunk) Descriptor 

func (*Chunk) Descriptor() ([]byte, []int)

func (*Chunk) GetData 

func (m *Chunk) GetData() []byte

func (*Chunk) GetError 

func (m *Chunk) GetError() []byte

func (*Chunk) GetName 

func (m *Chunk) GetName() string

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) Reset 

func (m *Chunk) Reset()

func (*Chunk) String 

func (m *Chunk) String() string

type LogEvent 

type LogEvent struct {
	Level   LogLevel `protobuf:"varint,1,opt,name=level,enum=proto.LogLevel" json:"level,omitempty"`
	Message string   `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

func LogEventProto 

func LogEventProto(e *log.Event) *LogEvent

LogEventProto converts a log.Event to a proto.LogEvent.

func (*LogEvent) Descriptor 

func (*LogEvent) Descriptor() ([]byte, []int)

func (*LogEvent) GetLevel 

func (m *LogEvent) GetLevel() LogLevel

func (*LogEvent) GetMessage 

func (m *LogEvent) GetMessage() string

func (*LogEvent) ProtoMessage 

func (*LogEvent) ProtoMessage()

func (*LogEvent) Reset 

func (m *LogEvent) Reset()

func (*LogEvent) String 

func (m *LogEvent) String() string

type LogLevel 

type LogLevel int32
const (
	LogLevel_Debug    LogLevel = 0
	LogLevel_Info     LogLevel = 1
	LogLevel_Warning  LogLevel = 2
	LogLevel_Error    LogLevel = 3
	LogLevel_Disabled LogLevel = 4
)

func LogLevelProto 

func LogLevelProto(lvl log.Level) LogLevel

LogLevelProto converts a log.Level to a proto.LogLevel.

func (LogLevel) EnumDescriptor 

func (LogLevel) EnumDescriptor() ([]byte, []int)

func (LogLevel) String 

func (x LogLevel) String() string

type LogTailRequest 

type LogTailRequest struct {
	Level LogLevel `protobuf:"varint,1,opt,name=level,enum=proto.LogLevel" json:"level,omitempty"`
}

func (*LogTailRequest) Descriptor 

func (*LogTailRequest) Descriptor() ([]byte, []int)

func (*LogTailRequest) GetLevel 

func (m *LogTailRequest) GetLevel() LogLevel

func (*LogTailRequest) ProtoMessage 

func (*LogTailRequest) ProtoMessage()

func (*LogTailRequest) Reset 

func (m *LogTailRequest) Reset()

func (*LogTailRequest) String 

func (m *LogTailRequest) String() string

type PullPrepareRequest 

type PullPrepareRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
}

func (*PullPrepareRequest) Descriptor 

func (*PullPrepareRequest) Descriptor() ([]byte, []int)

func (*PullPrepareRequest) GetName 

func (m *PullPrepareRequest) GetName() string

func (*PullPrepareRequest) GetOffset 

func (m *PullPrepareRequest) GetOffset() int64

func (*PullPrepareRequest) ProtoMessage 

func (*PullPrepareRequest) ProtoMessage()

func (*PullPrepareRequest) Reset 

func (m *PullPrepareRequest) Reset()

func (*PullPrepareRequest) String 

func (m *PullPrepareRequest) String() string

type PullPrepareResponse 

type PullPrepareResponse struct {
	Tx    []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Error []byte `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PullPrepareResponse) Descriptor 

func (*PullPrepareResponse) Descriptor() ([]byte, []int)

func (*PullPrepareResponse) GetError 

func (m *PullPrepareResponse) GetError() []byte

func (*PullPrepareResponse) GetTx 

func (m *PullPrepareResponse) GetTx() []byte

func (*PullPrepareResponse) ProtoMessage 

func (*PullPrepareResponse) ProtoMessage()

func (*PullPrepareResponse) Reset 

func (m *PullPrepareResponse) Reset()

func (*PullPrepareResponse) String 

func (m *PullPrepareResponse) String() string

type PullRequest 

type PullRequest struct {
	Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
}

func (*PullRequest) Descriptor 

func (*PullRequest) Descriptor() ([]byte, []int)

func (*PullRequest) GetTx 

func (m *PullRequest) GetTx() []byte

func (*PullRequest) ProtoMessage 

func (*PullRequest) ProtoMessage()

func (*PullRequest) Reset 

func (m *PullRequest) Reset()

func (*PullRequest) String 

func (m *PullRequest) String() string

type PushLogEntry 

type PushLogEntry struct {
	Seq   int64  `protobuf:"varint,1,opt,name=seq" json:"seq,omitempty"`
	Error []byte `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PushLogEntry) Descriptor 

func (*PushLogEntry) Descriptor() ([]byte, []int)

func (*PushLogEntry) GetError 

func (m *PushLogEntry) GetError() []byte

func (*PushLogEntry) GetSeq 

func (m *PushLogEntry) GetSeq() int64

func (*PushLogEntry) ProtoMessage 

func (*PushLogEntry) ProtoMessage()

func (*PushLogEntry) Reset 

func (m *PushLogEntry) Reset()

func (*PushLogEntry) String 

func (m *PushLogEntry) String() string

type PushLogRequest 

type PushLogRequest struct {
	Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
}

func (*PushLogRequest) Descriptor 

func (*PushLogRequest) Descriptor() ([]byte, []int)

func (*PushLogRequest) GetTx 

func (m *PushLogRequest) GetTx() []byte

func (*PushLogRequest) ProtoMessage 

func (*PushLogRequest) ProtoMessage()

func (*PushLogRequest) Reset 

func (m *PushLogRequest) Reset()

func (*PushLogRequest) String 

func (m *PushLogRequest) String() string

type PushPrepareRequest 

type PushPrepareRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Offset  int64  `protobuf:"varint,2,opt,name=offset" json:"offset,omitempty"`
	Append  bool   `protobuf:"varint,3,opt,name=append" json:"append,omitempty"`
	Dataset bool   `protobuf:"varint,4,opt,name=dataset" json:"dataset,omitempty"`
}

func (*PushPrepareRequest) Descriptor 

func (*PushPrepareRequest) Descriptor() ([]byte, []int)

func (*PushPrepareRequest) GetAppend 

func (m *PushPrepareRequest) GetAppend() bool

func (*PushPrepareRequest) GetDataset 

func (m *PushPrepareRequest) GetDataset() bool

func (*PushPrepareRequest) GetName 

func (m *PushPrepareRequest) GetName() string

func (*PushPrepareRequest) GetOffset 

func (m *PushPrepareRequest) GetOffset() int64

func (*PushPrepareRequest) ProtoMessage 

func (*PushPrepareRequest) ProtoMessage()

func (*PushPrepareRequest) Reset 

func (m *PushPrepareRequest) Reset()

func (*PushPrepareRequest) String 

func (m *PushPrepareRequest) String() string

type PushPrepareResponse 

type PushPrepareResponse struct {
	Tx    []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	Error []byte `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PushPrepareResponse) Descriptor 

func (*PushPrepareResponse) Descriptor() ([]byte, []int)

func (*PushPrepareResponse) GetError 

func (m *PushPrepareResponse) GetError() []byte

func (*PushPrepareResponse) GetTx 

func (m *PushPrepareResponse) GetTx() []byte

func (*PushPrepareResponse) ProtoMessage 

func (*PushPrepareResponse) ProtoMessage()

func (*PushPrepareResponse) Reset 

func (m *PushPrepareResponse) Reset()

func (*PushPrepareResponse) String 

func (m *PushPrepareResponse) String() string

type PushRequest 

type PushRequest struct {
	Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
}

PushRequest is sent as the first message to the push endpoint, followed by a stream of Chunk messages.

func (*PushRequest) Descriptor 

func (*PushRequest) Descriptor() ([]byte, []int)

func (*PushRequest) GetTx 

func (m *PushRequest) GetTx() []byte

func (*PushRequest) ProtoMessage 

func (*PushRequest) ProtoMessage()

func (*PushRequest) Reset 

func (m *PushRequest) Reset()

func (*PushRequest) String 

func (m *PushRequest) String() string

type PushResponse 

type PushResponse struct {
	Error []byte `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

func (*PushResponse) Descriptor 

func (*PushResponse) Descriptor() ([]byte, []int)

func (*PushResponse) GetError 

func (m *PushResponse) GetError() []byte

func (*PushResponse) ProtoMessage 

func (*PushResponse) ProtoMessage()

func (*PushResponse) Reset 

func (m *PushResponse) Reset()

func (*PushResponse) String 

func (m *PushResponse) String() string

type StatRequest 

type StatRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

func (*StatRequest) Descriptor 

func (*StatRequest) Descriptor() ([]byte, []int)

func (*StatRequest) GetName 

func (m *StatRequest) GetName() string

func (*StatRequest) ProtoMessage 

func (*StatRequest) ProtoMessage()

func (*StatRequest) Reset 

func (m *StatRequest) Reset()

func (*StatRequest) String 

func (m *StatRequest) String() string

type StatResponse 

type StatResponse struct {
	Size int64 `protobuf:"varint,1,opt,name=size" json:"size,omitempty"`
}

func (*StatResponse) Descriptor 

func (*StatResponse) Descriptor() ([]byte, []int)

func (*StatResponse) GetSize 

func (m *StatResponse) GetSize() int64

func (*StatResponse) ProtoMessage 

func (*StatResponse) ProtoMessage()

func (*StatResponse) Reset 

func (m *StatResponse) Reset()

func (*StatResponse) String 

func (m *StatResponse) String() string

type Vector 

type Vector struct {
	Split  bool     `protobuf:"varint,1,opt,name=split" json:"split,omitempty"`
	Names  []string `protobuf:"bytes,2,rep,name=names" json:"names,omitempty"`
	Values [][]byte `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"`
}

func (*Vector) Descriptor 

func (*Vector) Descriptor() ([]byte, []int)

func (*Vector) GetNames 

func (m *Vector) GetNames() []string

func (*Vector) GetSplit 

func (m *Vector) GetSplit() bool

func (*Vector) GetValues 

func (m *Vector) GetValues() [][]byte

func (*Vector) ProtoMessage 

func (*Vector) ProtoMessage()

func (*Vector) Reset 

func (m *Vector) Reset()

func (*Vector) String 

func (m *Vector) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.