Versions in this module Expand all Collapse all v2 v2.9.3 Mar 19, 2021 Changes in this version + func NewRuntimeEndpoints() []*api.Endpoint + func RegisterRuntimeHandler(s server.Server, hdlr RuntimeHandler, opts ...server.HandlerOption) error + func RegisterRuntimeServer(s *grpc.Server, srv RuntimeServer) + type CreateOptions struct + Args []string + Command []string + Env []string + Image string + Output string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateOptions) Descriptor() ([]byte, []int) + func (*CreateOptions) ProtoMessage() + func (m *CreateOptions) GetArgs() []string + func (m *CreateOptions) GetCommand() []string + func (m *CreateOptions) GetEnv() []string + func (m *CreateOptions) GetImage() string + func (m *CreateOptions) GetOutput() string + func (m *CreateOptions) GetType() string + func (m *CreateOptions) Reset() + func (m *CreateOptions) String() string + func (m *CreateOptions) XXX_DiscardUnknown() + func (m *CreateOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateOptions) XXX_Merge(src proto.Message) + func (m *CreateOptions) XXX_Size() int + func (m *CreateOptions) XXX_Unmarshal(b []byte) error + type CreateRequest struct + Options *CreateOptions + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateRequest) Descriptor() ([]byte, []int) + func (*CreateRequest) ProtoMessage() + func (m *CreateRequest) GetOptions() *CreateOptions + func (m *CreateRequest) GetService() *Service + func (m *CreateRequest) Reset() + func (m *CreateRequest) String() string + func (m *CreateRequest) XXX_DiscardUnknown() + func (m *CreateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateRequest) XXX_Merge(src proto.Message) + func (m *CreateRequest) XXX_Size() int + func (m *CreateRequest) XXX_Unmarshal(b []byte) error + type CreateResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreateResponse) Descriptor() ([]byte, []int) + func (*CreateResponse) ProtoMessage() + func (m *CreateResponse) Reset() + func (m *CreateResponse) String() string + func (m *CreateResponse) XXX_DiscardUnknown() + func (m *CreateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreateResponse) XXX_Merge(src proto.Message) + func (m *CreateResponse) XXX_Size() int + func (m *CreateResponse) XXX_Unmarshal(b []byte) error + type DeleteOptions struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteOptions) Descriptor() ([]byte, []int) + func (*DeleteOptions) ProtoMessage() + func (m *DeleteOptions) Reset() + func (m *DeleteOptions) String() string + func (m *DeleteOptions) XXX_DiscardUnknown() + func (m *DeleteOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteOptions) XXX_Merge(src proto.Message) + func (m *DeleteOptions) XXX_Size() int + func (m *DeleteOptions) XXX_Unmarshal(b []byte) error + type DeleteRequest struct + Options *DeleteOptions + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteRequest) Descriptor() ([]byte, []int) + func (*DeleteRequest) ProtoMessage() + func (m *DeleteRequest) GetOptions() *DeleteOptions + func (m *DeleteRequest) GetService() *Service + func (m *DeleteRequest) Reset() + func (m *DeleteRequest) String() string + func (m *DeleteRequest) XXX_DiscardUnknown() + func (m *DeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteRequest) XXX_Merge(src proto.Message) + func (m *DeleteRequest) XXX_Size() int + func (m *DeleteRequest) XXX_Unmarshal(b []byte) error + type DeleteResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeleteResponse) Descriptor() ([]byte, []int) + func (*DeleteResponse) ProtoMessage() + func (m *DeleteResponse) Reset() + func (m *DeleteResponse) String() string + func (m *DeleteResponse) XXX_DiscardUnknown() + func (m *DeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeleteResponse) XXX_Merge(src proto.Message) + func (m *DeleteResponse) XXX_Size() int + func (m *DeleteResponse) XXX_Unmarshal(b []byte) error + type Event struct + Service string + Timestamp int64 + Type string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Event) Descriptor() ([]byte, []int) + func (*Event) ProtoMessage() + func (m *Event) GetService() string + func (m *Event) GetTimestamp() int64 + func (m *Event) GetType() string + func (m *Event) GetVersion() string + func (m *Event) Reset() + func (m *Event) String() string + func (m *Event) XXX_DiscardUnknown() + func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Event) XXX_Merge(src proto.Message) + func (m *Event) XXX_Size() int + func (m *Event) XXX_Unmarshal(b []byte) error + type ListOptions struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListOptions) Descriptor() ([]byte, []int) + func (*ListOptions) ProtoMessage() + func (m *ListOptions) Reset() + func (m *ListOptions) String() string + func (m *ListOptions) XXX_DiscardUnknown() + func (m *ListOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListOptions) XXX_Merge(src proto.Message) + func (m *ListOptions) XXX_Size() int + func (m *ListOptions) XXX_Unmarshal(b []byte) error + type ListRequest struct + Options *ListOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListRequest) Descriptor() ([]byte, []int) + func (*ListRequest) ProtoMessage() + func (m *ListRequest) GetOptions() *ListOptions + func (m *ListRequest) Reset() + func (m *ListRequest) String() string + func (m *ListRequest) XXX_DiscardUnknown() + func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListRequest) XXX_Merge(src proto.Message) + func (m *ListRequest) XXX_Size() int + func (m *ListRequest) XXX_Unmarshal(b []byte) error + type ListResponse struct + Services []*Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ListResponse) Descriptor() ([]byte, []int) + func (*ListResponse) ProtoMessage() + func (m *ListResponse) GetServices() []*Service + func (m *ListResponse) Reset() + func (m *ListResponse) String() string + func (m *ListResponse) XXX_DiscardUnknown() + func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ListResponse) XXX_Merge(src proto.Message) + func (m *ListResponse) XXX_Size() int + func (m *ListResponse) XXX_Unmarshal(b []byte) error + type LogRecord struct + Message string + Metadata map[string]string + Timestamp int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogRecord) Descriptor() ([]byte, []int) + func (*LogRecord) ProtoMessage() + func (m *LogRecord) GetMessage() string + func (m *LogRecord) GetMetadata() map[string]string + func (m *LogRecord) GetTimestamp() int64 + func (m *LogRecord) Reset() + func (m *LogRecord) String() string + func (m *LogRecord) XXX_DiscardUnknown() + func (m *LogRecord) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogRecord) XXX_Merge(src proto.Message) + func (m *LogRecord) XXX_Size() int + func (m *LogRecord) XXX_Unmarshal(b []byte) error + type LogsOptions struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogsOptions) Descriptor() ([]byte, []int) + func (*LogsOptions) ProtoMessage() + func (m *LogsOptions) Reset() + func (m *LogsOptions) String() string + func (m *LogsOptions) XXX_DiscardUnknown() + func (m *LogsOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogsOptions) XXX_Merge(src proto.Message) + func (m *LogsOptions) XXX_Size() int + func (m *LogsOptions) XXX_Unmarshal(b []byte) error + type LogsRequest struct + Count int64 + Options *LogsOptions + Service string + Since int64 + Stream bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*LogsRequest) Descriptor() ([]byte, []int) + func (*LogsRequest) ProtoMessage() + func (m *LogsRequest) GetCount() int64 + func (m *LogsRequest) GetOptions() *LogsOptions + func (m *LogsRequest) GetService() string + func (m *LogsRequest) GetSince() int64 + func (m *LogsRequest) GetStream() bool + func (m *LogsRequest) Reset() + func (m *LogsRequest) String() string + func (m *LogsRequest) XXX_DiscardUnknown() + func (m *LogsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *LogsRequest) XXX_Merge(src proto.Message) + func (m *LogsRequest) XXX_Size() int + func (m *LogsRequest) XXX_Unmarshal(b []byte) error + type ReadOptions struct + Service string + Type string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadOptions) Descriptor() ([]byte, []int) + func (*ReadOptions) ProtoMessage() + func (m *ReadOptions) GetService() string + func (m *ReadOptions) GetType() string + func (m *ReadOptions) GetVersion() string + func (m *ReadOptions) Reset() + func (m *ReadOptions) String() string + func (m *ReadOptions) XXX_DiscardUnknown() + func (m *ReadOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadOptions) XXX_Merge(src proto.Message) + func (m *ReadOptions) XXX_Size() int + func (m *ReadOptions) XXX_Unmarshal(b []byte) error + type ReadRequest struct + Options *ReadOptions + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadRequest) Descriptor() ([]byte, []int) + func (*ReadRequest) ProtoMessage() + func (m *ReadRequest) GetOptions() *ReadOptions + func (m *ReadRequest) Reset() + func (m *ReadRequest) String() string + func (m *ReadRequest) XXX_DiscardUnknown() + func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadRequest) XXX_Merge(src proto.Message) + func (m *ReadRequest) XXX_Size() int + func (m *ReadRequest) XXX_Unmarshal(b []byte) error + type ReadResponse struct + Services []*Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ReadResponse) Descriptor() ([]byte, []int) + func (*ReadResponse) ProtoMessage() + func (m *ReadResponse) GetServices() []*Service + func (m *ReadResponse) Reset() + func (m *ReadResponse) String() string + func (m *ReadResponse) XXX_DiscardUnknown() + func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ReadResponse) XXX_Merge(src proto.Message) + func (m *ReadResponse) XXX_Size() int + func (m *ReadResponse) XXX_Unmarshal(b []byte) error + type RuntimeClient interface + Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) + Logs func(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Runtime_LogsClient, error) + Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) + Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) + func NewRuntimeClient(cc *grpc.ClientConn) RuntimeClient + type RuntimeHandler interface + Create func(context.Context, *CreateRequest, *CreateResponse) error + Delete func(context.Context, *DeleteRequest, *DeleteResponse) error + Logs func(context.Context, *LogsRequest, Runtime_LogsStream) error + Read func(context.Context, *ReadRequest, *ReadResponse) error + Update func(context.Context, *UpdateRequest, *UpdateResponse) error + type RuntimeServer interface + Create func(context.Context, *CreateRequest) (*CreateResponse, error) + Delete func(context.Context, *DeleteRequest) (*DeleteResponse, error) + Logs func(*LogsRequest, Runtime_LogsServer) error + Read func(context.Context, *ReadRequest) (*ReadResponse, error) + Update func(context.Context, *UpdateRequest) (*UpdateResponse, error) + type RuntimeService interface + Create func(ctx context.Context, in *CreateRequest, opts ...client.CallOption) (*CreateResponse, error) + Delete func(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error) + Logs func(ctx context.Context, in *LogsRequest, opts ...client.CallOption) (Runtime_LogsService, error) + Read func(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) + Update func(ctx context.Context, in *UpdateRequest, opts ...client.CallOption) (*UpdateResponse, error) + func NewRuntimeService(name string, c client.Client) RuntimeService + type Runtime_LogsClient interface + Recv func() (*LogRecord, error) + type Runtime_LogsServer interface + Send func(*LogRecord) error + type Runtime_LogsService interface + Close func() error + Context func() context.Context + Recv func() (*LogRecord, error) + RecvMsg func(interface{}) error + SendMsg func(interface{}) error + type Runtime_LogsStream interface + Close func() error + Context func() context.Context + RecvMsg func(interface{}) error + Send func(*LogRecord) error + SendMsg func(interface{}) error + type Service struct + Metadata map[string]string + Name string + Source string + Version string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Service) Descriptor() ([]byte, []int) + func (*Service) ProtoMessage() + func (m *Service) GetMetadata() map[string]string + func (m *Service) GetName() string + func (m *Service) GetSource() string + func (m *Service) GetVersion() string + func (m *Service) Reset() + func (m *Service) String() string + func (m *Service) XXX_DiscardUnknown() + func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Service) XXX_Merge(src proto.Message) + func (m *Service) XXX_Size() int + func (m *Service) XXX_Unmarshal(b []byte) error + type UnimplementedRuntimeServer struct + func (*UnimplementedRuntimeServer) Create(ctx context.Context, req *CreateRequest) (*CreateResponse, error) + func (*UnimplementedRuntimeServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error) + func (*UnimplementedRuntimeServer) Logs(req *LogsRequest, srv Runtime_LogsServer) error + func (*UnimplementedRuntimeServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error) + func (*UnimplementedRuntimeServer) Update(ctx context.Context, req *UpdateRequest) (*UpdateResponse, error) + type UpdateOptions struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateOptions) Descriptor() ([]byte, []int) + func (*UpdateOptions) ProtoMessage() + func (m *UpdateOptions) Reset() + func (m *UpdateOptions) String() string + func (m *UpdateOptions) XXX_DiscardUnknown() + func (m *UpdateOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateOptions) XXX_Merge(src proto.Message) + func (m *UpdateOptions) XXX_Size() int + func (m *UpdateOptions) XXX_Unmarshal(b []byte) error + type UpdateRequest struct + Options *UpdateOptions + Service *Service + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateRequest) Descriptor() ([]byte, []int) + func (*UpdateRequest) ProtoMessage() + func (m *UpdateRequest) GetOptions() *UpdateOptions + func (m *UpdateRequest) GetService() *Service + func (m *UpdateRequest) Reset() + func (m *UpdateRequest) String() string + func (m *UpdateRequest) XXX_DiscardUnknown() + func (m *UpdateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateRequest) XXX_Merge(src proto.Message) + func (m *UpdateRequest) XXX_Size() int + func (m *UpdateRequest) XXX_Unmarshal(b []byte) error + type UpdateResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*UpdateResponse) Descriptor() ([]byte, []int) + func (*UpdateResponse) ProtoMessage() + func (m *UpdateResponse) Reset() + func (m *UpdateResponse) String() string + func (m *UpdateResponse) XXX_DiscardUnknown() + func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *UpdateResponse) XXX_Merge(src proto.Message) + func (m *UpdateResponse) XXX_Size() int + func (m *UpdateResponse) XXX_Unmarshal(b []byte) error
Go to main page