protocol

package
v0.0.0-...-d046166 Latest Latest
Warning

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

 Go to latest Published: Dec 10, 2020 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Overview

Package protocol contains gRPC services and protocol buffer messages used in the core framework.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLoggingServer 

func RegisterLoggingServer(s *grpc.Server, srv LoggingServer)

func RegisterPingServer 

func RegisterPingServer(s *grpc.Server, srv PingServer)

Types

type InitBundleServerRequest 

type InitBundleServerRequest struct {
	Vars                 map[string]string `` /* 149-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*InitBundleServerRequest) Descriptor 

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

func (*InitBundleServerRequest) GetVars 

func (m *InitBundleServerRequest) GetVars() map[string]string

func (*InitBundleServerRequest) ProtoMessage 

func (*InitBundleServerRequest) ProtoMessage()

func (*InitBundleServerRequest) Reset 

func (m *InitBundleServerRequest) Reset()

func (*InitBundleServerRequest) String 

func (m *InitBundleServerRequest) String() string

func (*InitBundleServerRequest) XXX_DiscardUnknown 

func (m *InitBundleServerRequest) XXX_DiscardUnknown()

func (*InitBundleServerRequest) XXX_Marshal 

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

func (*InitBundleServerRequest) XXX_Merge 

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

func (*InitBundleServerRequest) XXX_Size 

func (m *InitBundleServerRequest) XXX_Size() int

func (*InitBundleServerRequest) XXX_Unmarshal 

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

type InitBundleServerResponse 

type InitBundleServerResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	ErrorMessage         string   `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InitBundleServerResponse) Descriptor 

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

func (*InitBundleServerResponse) GetErrorMessage 

func (m *InitBundleServerResponse) GetErrorMessage() string

func (*InitBundleServerResponse) GetSuccess 

func (m *InitBundleServerResponse) GetSuccess() bool

func (*InitBundleServerResponse) ProtoMessage 

func (*InitBundleServerResponse) ProtoMessage()

func (*InitBundleServerResponse) Reset 

func (m *InitBundleServerResponse) Reset()

func (*InitBundleServerResponse) String 

func (m *InitBundleServerResponse) String() string

func (*InitBundleServerResponse) XXX_DiscardUnknown 

func (m *InitBundleServerResponse) XXX_DiscardUnknown()

func (*InitBundleServerResponse) XXX_Marshal 

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

func (*InitBundleServerResponse) XXX_Merge 

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

func (*InitBundleServerResponse) XXX_Size 

func (m *InitBundleServerResponse) XXX_Size() int

func (*InitBundleServerResponse) XXX_Unmarshal 

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

type LogEntry 

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

func (*LogEntry) Descriptor 

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

func (*LogEntry) GetMsg 

func (m *LogEntry) GetMsg() string

func (*LogEntry) ProtoMessage 

func (*LogEntry) ProtoMessage()

func (*LogEntry) Reset 

func (m *LogEntry) Reset()

func (*LogEntry) String 

func (m *LogEntry) String() string

func (*LogEntry) XXX_DiscardUnknown 

func (m *LogEntry) XXX_DiscardUnknown()

func (*LogEntry) XXX_Marshal 

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

func (*LogEntry) XXX_Merge 

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

func (*LogEntry) XXX_Size 

func (m *LogEntry) XXX_Size() int

func (*LogEntry) XXX_Unmarshal 

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

type LoggingClient 

type LoggingClient interface {
	// ReadLogs subscribes to logs emitted by gRPC services.
	// At the beginning of the call, one ReadLogsResponse with empty entry is
	// sent to indicate success of subscription. Afterwards ReadLogsResponse is
	// sent back as a stream as logs are emitted. The response stream is closed
	// when the client closes the request stream or any error occurs.
	// At most one client can have an active call of this method at a time.
	ReadLogs(ctx context.Context, opts ...grpc.CallOption) (Logging_ReadLogsClient, error)
}

LoggingClient is the client API for Logging service.

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

func NewLoggingClient 

func NewLoggingClient(cc *grpc.ClientConn) LoggingClient

type LoggingServer 

type LoggingServer interface {
	// ReadLogs subscribes to logs emitted by gRPC services.
	// At the beginning of the call, one ReadLogsResponse with empty entry is
	// sent to indicate success of subscription. Afterwards ReadLogsResponse is
	// sent back as a stream as logs are emitted. The response stream is closed
	// when the client closes the request stream or any error occurs.
	// At most one client can have an active call of this method at a time.
	ReadLogs(Logging_ReadLogsServer) error
}

LoggingServer is the server API for Logging service.

type Logging_ReadLogsClient 

type Logging_ReadLogsClient interface {
	Send(*ReadLogsRequest) error
	Recv() (*ReadLogsResponse, error)
	grpc.ClientStream
}

type Logging_ReadLogsServer 

type Logging_ReadLogsServer interface {
	Send(*ReadLogsResponse) error
	Recv() (*ReadLogsRequest, error)
	grpc.ServerStream
}

type PingClient 

type PingClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}

PingClient is the client API for Ping service.

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

func NewPingClient 

func NewPingClient(cc *grpc.ClientConn) PingClient

type PingRequest 

type PingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor 

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

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset 

func (m *PingRequest) Reset()

func (*PingRequest) String 

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown 

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal 

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

func (*PingRequest) XXX_Merge 

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

func (*PingRequest) XXX_Size 

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal 

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

type PingResponse 

type PingResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingResponse) Descriptor 

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

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset 

func (m *PingResponse) Reset()

func (*PingResponse) String 

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown 

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal 

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

func (*PingResponse) XXX_Merge 

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

func (*PingResponse) XXX_Size 

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal 

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

type PingServer 

type PingServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
}

PingServer is the server API for Ping service.

type ReadLogsRequest 

type ReadLogsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReadLogsRequest) Descriptor 

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

func (*ReadLogsRequest) ProtoMessage 

func (*ReadLogsRequest) ProtoMessage()

func (*ReadLogsRequest) Reset 

func (m *ReadLogsRequest) Reset()

func (*ReadLogsRequest) String 

func (m *ReadLogsRequest) String() string

func (*ReadLogsRequest) XXX_DiscardUnknown 

func (m *ReadLogsRequest) XXX_DiscardUnknown()

func (*ReadLogsRequest) XXX_Marshal 

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

func (*ReadLogsRequest) XXX_Merge 

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

func (*ReadLogsRequest) XXX_Size 

func (m *ReadLogsRequest) XXX_Size() int

func (*ReadLogsRequest) XXX_Unmarshal 

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

type ReadLogsResponse 

type ReadLogsResponse struct {
	// entry is an emitted log entry. It is missing for an initial
	// ReadLogsResponse to indicate success of subscription.
	Entry                *LogEntry `protobuf:"bytes,1,opt,name=entry,proto3" json:"entry,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReadLogsResponse) Descriptor 

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

func (*ReadLogsResponse) GetEntry 

func (m *ReadLogsResponse) GetEntry() *LogEntry

func (*ReadLogsResponse) ProtoMessage 

func (*ReadLogsResponse) ProtoMessage()

func (*ReadLogsResponse) Reset 

func (m *ReadLogsResponse) Reset()

func (*ReadLogsResponse) String 

func (m *ReadLogsResponse) String() string

func (*ReadLogsResponse) XXX_DiscardUnknown 

func (m *ReadLogsResponse) XXX_DiscardUnknown()

func (*ReadLogsResponse) XXX_Marshal 

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

func (*ReadLogsResponse) XXX_Merge 

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

func (*ReadLogsResponse) XXX_Size 

func (m *ReadLogsResponse) XXX_Size() int

func (*ReadLogsResponse) XXX_Unmarshal 

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

type UnimplementedLoggingServer 

type UnimplementedLoggingServer struct {
}

UnimplementedLoggingServer can be embedded to have forward compatible implementations.

func (*UnimplementedLoggingServer) ReadLogs 

func (*UnimplementedLoggingServer) ReadLogs(srv Logging_ReadLogsServer) error

type UnimplementedPingServer 

type UnimplementedPingServer struct {
}

UnimplementedPingServer can be embedded to have forward compatible implementations.

func (*UnimplementedPingServer) Ping 

func (*UnimplementedPingServer) Ping(ctx context.Context, req *PingRequest) (*PingResponse, 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.