communication

package
v1.0.2 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2020 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLogCollectorServer 

func RegisterLogCollectorServer(s *grpc.Server, srv LogCollectorServer)

func RegisterLogReceiverServer 

func RegisterLogReceiverServer(s *grpc.Server, srv LogReceiverServer)

Types

type FileList 

type FileList struct {
	Paths                []*LogPath `protobuf:"bytes,1,rep,name=paths,proto3" json:"paths,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*FileList) Descriptor 

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

func (*FileList) GetPaths 

func (m *FileList) GetPaths() []*LogPath

func (*FileList) ProtoMessage 

func (*FileList) ProtoMessage()

func (*FileList) Reset 

func (m *FileList) Reset()

func (*FileList) String 

func (m *FileList) String() string

func (*FileList) XXX_DiscardUnknown 

func (m *FileList) XXX_DiscardUnknown()

func (*FileList) XXX_Marshal 

func (m *FileList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FileList) XXX_Merge 

func (m *FileList) XXX_Merge(src proto.Message)

func (*FileList) XXX_Size 

func (m *FileList) XXX_Size() int

func (*FileList) XXX_Unmarshal 

func (m *FileList) XXX_Unmarshal(b []byte) error

type LogCollectorClient 

type LogCollectorClient interface {
	GetFileList(ctx context.Context, in *LogPath, opts ...grpc.CallOption) (*FileList, error)
	ReadLogFile(ctx context.Context, in *LogPath, opts ...grpc.CallOption) (*LogFile, error)
}

LogCollectorClient is the client API for LogCollector service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLogCollectorClient 

func NewLogCollectorClient(cc *grpc.ClientConn) LogCollectorClient

type LogCollectorServer 

type LogCollectorServer interface {
	GetFileList(context.Context, *LogPath) (*FileList, error)
	ReadLogFile(context.Context, *LogPath) (*LogFile, error)
}

LogCollectorServer is the server API for LogCollector service.

type LogFile 

type LogFile struct {
	Path                 *LogPath `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Content              string   `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogFile) Descriptor 

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

func (*LogFile) GetContent 

func (m *LogFile) GetContent() string

func (*LogFile) GetPath 

func (m *LogFile) GetPath() *LogPath

func (*LogFile) ProtoMessage 

func (*LogFile) ProtoMessage()

func (*LogFile) Reset 

func (m *LogFile) Reset()

func (*LogFile) String 

func (m *LogFile) String() string

func (*LogFile) XXX_DiscardUnknown 

func (m *LogFile) XXX_DiscardUnknown()

func (*LogFile) XXX_Marshal 

func (m *LogFile) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogFile) XXX_Merge 

func (m *LogFile) XXX_Merge(src proto.Message)

func (*LogFile) XXX_Size 

func (m *LogFile) XXX_Size() int

func (*LogFile) XXX_Unmarshal 

func (m *LogFile) XXX_Unmarshal(b []byte) error

type LogPath 

type LogPath struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogPath) Descriptor 

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

func (*LogPath) GetPath 

func (m *LogPath) GetPath() string

func (*LogPath) ProtoMessage 

func (*LogPath) ProtoMessage()

func (*LogPath) Reset 

func (m *LogPath) Reset()

func (*LogPath) String 

func (m *LogPath) String() string

func (*LogPath) XXX_DiscardUnknown 

func (m *LogPath) XXX_DiscardUnknown()

func (*LogPath) XXX_Marshal 

func (m *LogPath) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogPath) XXX_Merge 

func (m *LogPath) XXX_Merge(src proto.Message)

func (*LogPath) XXX_Size 

func (m *LogPath) XXX_Size() int

func (*LogPath) XXX_Unmarshal 

func (m *LogPath) XXX_Unmarshal(b []byte) error

type LogReceiverClient 

type LogReceiverClient interface {
	ReceiveLoggedText(ctx context.Context, in *LogText, opts ...grpc.CallOption) (*any.Any, error)
}

LogReceiverClient is the client API for LogReceiver service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewLogReceiverClient 

func NewLogReceiverClient(cc *grpc.ClientConn) LogReceiverClient

type LogReceiverServer 

type LogReceiverServer interface {
	ReceiveLoggedText(context.Context, *LogText) (*any.Any, error)
}

LogReceiverServer is the server API for LogReceiver service.

type LogText 

type LogText struct {
	LoggedAt             *timestamp.Timestamp `protobuf:"bytes,1,opt,name=logged_at,json=loggedAt,proto3" json:"logged_at,omitempty"`
	LogMessage           string               `protobuf:"bytes,2,opt,name=log_message,json=logMessage,proto3" json:"log_message,omitempty"`
	LogFile              *LogPath             `protobuf:"bytes,3,opt,name=log_file,json=logFile,proto3" json:"log_file,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*LogText) Descriptor 

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

func (*LogText) GetLogFile 

func (m *LogText) GetLogFile() *LogPath

func (*LogText) GetLogMessage 

func (m *LogText) GetLogMessage() string

func (*LogText) GetLoggedAt 

func (m *LogText) GetLoggedAt() *timestamp.Timestamp

func (*LogText) ProtoMessage 

func (*LogText) ProtoMessage()

func (*LogText) Reset 

func (m *LogText) Reset()

func (*LogText) String 

func (m *LogText) String() string

func (*LogText) XXX_DiscardUnknown 

func (m *LogText) XXX_DiscardUnknown()

func (*LogText) XXX_Marshal 

func (m *LogText) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogText) XXX_Merge 

func (m *LogText) XXX_Merge(src proto.Message)

func (*LogText) XXX_Size 

func (m *LogText) XXX_Size() int

func (*LogText) XXX_Unmarshal 

func (m *LogText) XXX_Unmarshal(b []byte) error

type UnimplementedLogCollectorServer 

type UnimplementedLogCollectorServer struct {
}

UnimplementedLogCollectorServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogCollectorServer) GetFileList 

func (*UnimplementedLogCollectorServer) GetFileList(ctx context.Context, req *LogPath) (*FileList, error)

func (*UnimplementedLogCollectorServer) ReadLogFile 

func (*UnimplementedLogCollectorServer) ReadLogFile(ctx context.Context, req *LogPath) (*LogFile, error)

type UnimplementedLogReceiverServer 

type UnimplementedLogReceiverServer struct {
}

UnimplementedLogReceiverServer can be embedded to have forward compatible implementations.

func (*UnimplementedLogReceiverServer) ReceiveLoggedText 

func (*UnimplementedLogReceiverServer) ReceiveLoggedText(ctx context.Context, req *LogText) (*any.Any, error)

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.