Documentation ¶
Index ¶
- Variables
- func NewBuildEndpoints() []*api.Endpoint
- func NewRuntimeEndpoints() []*api.Endpoint
- func NewSourceEndpoints() []*api.Endpoint
- func RegisterBuildHandler(s server.Server, hdlr BuildHandler, opts ...server.HandlerOption) error
- func RegisterBuildServer(s grpc.ServiceRegistrar, srv BuildServer)
- func RegisterRuntimeHandler(s server.Server, hdlr RuntimeHandler, opts ...server.HandlerOption) error
- func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
- func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error
- func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)
- type BuildClient
- type BuildHandler
- type BuildReadResponse
- type BuildServer
- type BuildService
- type Build_ReadClient
- type Build_ReadServer
- type Build_ReadService
- type Build_ReadStream
- type CreateOptions
- func (*CreateOptions) Descriptor() ([]byte, []int)deprecated
- func (x *CreateOptions) GetArgs() []string
- func (x *CreateOptions) GetCommand() []string
- func (x *CreateOptions) GetEntrypoint() string
- func (x *CreateOptions) GetEnv() []string
- func (x *CreateOptions) GetForce() bool
- func (x *CreateOptions) GetImage() string
- func (x *CreateOptions) GetInstances() int64
- func (x *CreateOptions) GetNamespace() string
- func (x *CreateOptions) GetOutput() string
- func (x *CreateOptions) GetSecrets() map[string]string
- func (x *CreateOptions) GetType() string
- func (x *CreateOptions) GetVolumes() map[string]string
- func (*CreateOptions) ProtoMessage()
- func (x *CreateOptions) ProtoReflect() protoreflect.Message
- func (x *CreateOptions) Reset()
- func (x *CreateOptions) String() string
- type CreateRequest
- func (*CreateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateRequest) GetOptions() *CreateOptions
- func (x *CreateRequest) GetResource() *Resource
- func (*CreateRequest) ProtoMessage()
- func (x *CreateRequest) ProtoReflect() protoreflect.Message
- func (x *CreateRequest) Reset()
- func (x *CreateRequest) String() string
- type CreateResponse
- type DeleteOptions
- type DeleteRequest
- func (*DeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteRequest) GetOptions() *DeleteOptions
- func (x *DeleteRequest) GetResource() *Resource
- func (*DeleteRequest) ProtoMessage()
- func (x *DeleteRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteRequest) Reset()
- func (x *DeleteRequest) String() string
- type DeleteResponse
- type ListOptions
- type ListRequest
- type ListResponse
- type LogRecord
- func (*LogRecord) Descriptor() ([]byte, []int)deprecated
- func (x *LogRecord) GetMessage() string
- func (x *LogRecord) GetMetadata() map[string]string
- func (x *LogRecord) GetTimestamp() int64
- func (*LogRecord) ProtoMessage()
- func (x *LogRecord) ProtoReflect() protoreflect.Message
- func (x *LogRecord) Reset()
- func (x *LogRecord) String() string
- type LogsOptions
- type LogsRequest
- func (*LogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *LogsRequest) GetCount() int64
- func (x *LogsRequest) GetOptions() *LogsOptions
- func (x *LogsRequest) GetService() string
- func (x *LogsRequest) GetSince() int64
- func (x *LogsRequest) GetStream() bool
- func (x *LogsRequest) GetVersion() string
- func (*LogsRequest) ProtoMessage()
- func (x *LogsRequest) ProtoReflect() protoreflect.Message
- func (x *LogsRequest) Reset()
- func (x *LogsRequest) String() string
- type Namespace
- type NetworkPolicy
- func (*NetworkPolicy) Descriptor() ([]byte, []int)deprecated
- func (x *NetworkPolicy) GetAllowedlabels() map[string]string
- func (x *NetworkPolicy) GetName() string
- func (x *NetworkPolicy) GetNamespace() string
- func (*NetworkPolicy) ProtoMessage()
- func (x *NetworkPolicy) ProtoReflect() protoreflect.Message
- func (x *NetworkPolicy) Reset()
- func (x *NetworkPolicy) String() string
- type ReadOptions
- func (*ReadOptions) Descriptor() ([]byte, []int)deprecated
- func (x *ReadOptions) GetNamespace() string
- func (x *ReadOptions) GetService() string
- func (x *ReadOptions) GetType() string
- func (x *ReadOptions) GetVersion() string
- func (*ReadOptions) ProtoMessage()
- func (x *ReadOptions) ProtoReflect() protoreflect.Message
- func (x *ReadOptions) Reset()
- func (x *ReadOptions) String() string
- type ReadRequest
- type ReadResponse
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetNamespace() *Namespace
- func (x *Resource) GetNetworkpolicy() *NetworkPolicy
- func (x *Resource) GetResourcequota() *ResourceQuota
- func (x *Resource) GetService() *Service
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type ResourceQuota
- func (*ResourceQuota) Descriptor() ([]byte, []int)deprecated
- func (x *ResourceQuota) GetLimits() *Resources
- func (x *ResourceQuota) GetName() string
- func (x *ResourceQuota) GetNamespace() string
- func (x *ResourceQuota) GetRequests() *Resources
- func (*ResourceQuota) ProtoMessage()
- func (x *ResourceQuota) ProtoReflect() protoreflect.Message
- func (x *ResourceQuota) Reset()
- func (x *ResourceQuota) String() string
- type Resources
- func (*Resources) Descriptor() ([]byte, []int)deprecated
- func (x *Resources) GetCPU() int32
- func (x *Resources) GetEphemeralStorage() int32
- func (x *Resources) GetMemory() int32
- func (*Resources) ProtoMessage()
- func (x *Resources) ProtoReflect() protoreflect.Message
- func (x *Resources) Reset()
- func (x *Resources) String() string
- type RuntimeClient
- type RuntimeHandler
- type RuntimeServer
- type RuntimeService
- type Runtime_LogsClient
- type Runtime_LogsServer
- type Runtime_LogsService
- type Runtime_LogsStream
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetMetadata() map[string]string
- func (x *Service) GetName() string
- func (x *Service) GetSource() string
- func (x *Service) GetStatus() int32
- func (x *Service) GetVersion() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type SourceClient
- type SourceHandler
- type SourceServer
- type SourceService
- type Source_UploadClient
- type Source_UploadServer
- type Source_UploadService
- type Source_UploadStream
- type UnimplementedBuildServer
- type UnimplementedRuntimeServer
- func (UnimplementedRuntimeServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
- func (UnimplementedRuntimeServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
- func (UnimplementedRuntimeServer) Logs(*LogsRequest, Runtime_LogsServer) error
- func (UnimplementedRuntimeServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
- func (UnimplementedRuntimeServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
- type UnimplementedSourceServer
- type UnsafeBuildServer
- type UnsafeRuntimeServer
- type UnsafeSourceServer
- type UpdateOptions
- func (*UpdateOptions) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateOptions) GetEntrypoint() string
- func (x *UpdateOptions) GetInstances() int64
- func (x *UpdateOptions) GetNamespace() string
- func (*UpdateOptions) ProtoMessage()
- func (x *UpdateOptions) ProtoReflect() protoreflect.Message
- func (x *UpdateOptions) Reset()
- func (x *UpdateOptions) String() string
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetOptions() *UpdateOptions
- func (x *UpdateRequest) GetResource() *Resource
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateResponse
- type UploadRequest
- func (*UploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadRequest) GetData() []byte
- func (x *UploadRequest) GetService() *Service
- func (*UploadRequest) ProtoMessage()
- func (x *UploadRequest) ProtoReflect() protoreflect.Message
- func (x *UploadRequest) Reset()
- func (x *UploadRequest) String() string
- type UploadResponse
Constants ¶
This section is empty.
Variables ¶
var Build_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runtime.Build", HandlerType: (*BuildServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Read", Handler: _Build_Read_Handler, ServerStreams: true, }, }, Metadata: "proto/runtime/runtime.proto", }
Build_ServiceDesc is the grpc.ServiceDesc for Build service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_runtime_runtime_proto protoreflect.FileDescriptor
var Runtime_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runtime.Runtime", HandlerType: (*RuntimeServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Create", Handler: _Runtime_Create_Handler, }, { MethodName: "Read", Handler: _Runtime_Read_Handler, }, { MethodName: "Delete", Handler: _Runtime_Delete_Handler, }, { MethodName: "Update", Handler: _Runtime_Update_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Logs", Handler: _Runtime_Logs_Handler, ServerStreams: true, }, }, Metadata: "proto/runtime/runtime.proto", }
Runtime_ServiceDesc is the grpc.ServiceDesc for Runtime service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Source_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runtime.Source", HandlerType: (*SourceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Upload", Handler: _Source_Upload_Handler, ClientStreams: true, }, }, Metadata: "proto/runtime/runtime.proto", }
Source_ServiceDesc is the grpc.ServiceDesc for Source service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func NewBuildEndpoints ¶
func NewRuntimeEndpoints ¶
func NewSourceEndpoints ¶
func RegisterBuildHandler ¶
func RegisterBuildHandler(s server.Server, hdlr BuildHandler, opts ...server.HandlerOption) error
func RegisterBuildServer ¶
func RegisterBuildServer(s grpc.ServiceRegistrar, srv BuildServer)
func RegisterRuntimeHandler ¶
func RegisterRuntimeHandler(s server.Server, hdlr RuntimeHandler, opts ...server.HandlerOption) error
func RegisterRuntimeServer ¶
func RegisterRuntimeServer(s grpc.ServiceRegistrar, srv RuntimeServer)
func RegisterSourceHandler ¶
func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error
func RegisterSourceServer ¶
func RegisterSourceServer(s grpc.ServiceRegistrar, srv SourceServer)
Types ¶
type BuildClient ¶
type BuildClient interface {
Read(ctx context.Context, in *Service, opts ...grpc.CallOption) (Build_ReadClient, error)
}
BuildClient is the client API for Build service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewBuildClient ¶
func NewBuildClient(cc grpc.ClientConnInterface) BuildClient
type BuildHandler ¶
type BuildHandler interface {
Read(context.Context, *Service, Build_ReadStream) error
}
type BuildReadResponse ¶
type BuildReadResponse struct { Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*BuildReadResponse) Descriptor
deprecated
func (*BuildReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use BuildReadResponse.ProtoReflect.Descriptor instead.
func (*BuildReadResponse) GetData ¶
func (x *BuildReadResponse) GetData() []byte
func (*BuildReadResponse) ProtoMessage ¶
func (*BuildReadResponse) ProtoMessage()
func (*BuildReadResponse) ProtoReflect ¶
func (x *BuildReadResponse) ProtoReflect() protoreflect.Message
func (*BuildReadResponse) Reset ¶
func (x *BuildReadResponse) Reset()
func (*BuildReadResponse) String ¶
func (x *BuildReadResponse) String() string
type BuildServer ¶
type BuildServer interface { Read(*Service, Build_ReadServer) error // contains filtered or unexported methods }
BuildServer is the server API for Build service. All implementations must embed UnimplementedBuildServer for forward compatibility
type BuildService ¶
type BuildService interface {
Read(ctx context.Context, in *Service, opts ...client.CallOption) (Build_ReadService, error)
}
func NewBuildService ¶
func NewBuildService(name string, c client.Client) BuildService
type Build_ReadClient ¶
type Build_ReadClient interface { Recv() (*BuildReadResponse, error) grpc.ClientStream }
type Build_ReadServer ¶
type Build_ReadServer interface { Send(*BuildReadResponse) error grpc.ServerStream }
type Build_ReadService ¶
type Build_ReadStream ¶
type CreateOptions ¶
type CreateOptions struct { // command to pass in Command []string `protobuf:"bytes,1,rep,name=command,proto3" json:"command,omitempty"` // args to pass into command Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"` // environment to pass in Env []string `protobuf:"bytes,3,rep,name=env,proto3" json:"env,omitempty"` // output to send to Output string `protobuf:"bytes,4,opt,name=output,proto3" json:"output,omitempty"` // create type of service Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"` // image to use Image string `protobuf:"bytes,6,opt,name=image,proto3" json:"image,omitempty"` // namespace to create the service in Namespace string `protobuf:"bytes,7,opt,name=namespace,proto3" json:"namespace,omitempty"` // secrets to use for the service Secrets map[string]string `` /* 155-byte string literal not displayed */ // entrypoint within the source Entrypoint string `protobuf:"bytes,9,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"` // volumes to mount Volumes map[string]string `` /* 156-byte string literal not displayed */ // number of instances Instances int64 `protobuf:"varint,11,opt,name=instances,proto3" json:"instances,omitempty"` // force rebuild and restart the service Force bool `protobuf:"varint,12,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
func (*CreateOptions) Descriptor
deprecated
func (*CreateOptions) Descriptor() ([]byte, []int)
Deprecated: Use CreateOptions.ProtoReflect.Descriptor instead.
func (*CreateOptions) GetArgs ¶
func (x *CreateOptions) GetArgs() []string
func (*CreateOptions) GetCommand ¶
func (x *CreateOptions) GetCommand() []string
func (*CreateOptions) GetEntrypoint ¶
func (x *CreateOptions) GetEntrypoint() string
func (*CreateOptions) GetEnv ¶
func (x *CreateOptions) GetEnv() []string
func (*CreateOptions) GetForce ¶
func (x *CreateOptions) GetForce() bool
func (*CreateOptions) GetImage ¶
func (x *CreateOptions) GetImage() string
func (*CreateOptions) GetInstances ¶
func (x *CreateOptions) GetInstances() int64
func (*CreateOptions) GetNamespace ¶
func (x *CreateOptions) GetNamespace() string
func (*CreateOptions) GetOutput ¶
func (x *CreateOptions) GetOutput() string
func (*CreateOptions) GetSecrets ¶
func (x *CreateOptions) GetSecrets() map[string]string
func (*CreateOptions) GetType ¶
func (x *CreateOptions) GetType() string
func (*CreateOptions) GetVolumes ¶
func (x *CreateOptions) GetVolumes() map[string]string
func (*CreateOptions) ProtoMessage ¶
func (*CreateOptions) ProtoMessage()
func (*CreateOptions) ProtoReflect ¶
func (x *CreateOptions) ProtoReflect() protoreflect.Message
func (*CreateOptions) Reset ¶
func (x *CreateOptions) Reset()
func (*CreateOptions) String ¶
func (x *CreateOptions) String() string
type CreateRequest ¶
type CreateRequest struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Options *CreateOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*CreateRequest) Descriptor
deprecated
func (*CreateRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.
func (*CreateRequest) GetOptions ¶
func (x *CreateRequest) GetOptions() *CreateOptions
func (*CreateRequest) GetResource ¶
func (x *CreateRequest) GetResource() *Resource
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) ProtoReflect ¶
func (x *CreateRequest) ProtoReflect() protoreflect.Message
func (*CreateRequest) Reset ¶
func (x *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (x *CreateRequest) String() string
type CreateResponse ¶
type CreateResponse struct {
// contains filtered or unexported fields
}
func (*CreateResponse) Descriptor
deprecated
func (*CreateResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) ProtoReflect ¶
func (x *CreateResponse) ProtoReflect() protoreflect.Message
func (*CreateResponse) Reset ¶
func (x *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (x *CreateResponse) String() string
type DeleteOptions ¶
type DeleteOptions struct { // namespace of the service Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*DeleteOptions) Descriptor
deprecated
func (*DeleteOptions) Descriptor() ([]byte, []int)
Deprecated: Use DeleteOptions.ProtoReflect.Descriptor instead.
func (*DeleteOptions) GetNamespace ¶
func (x *DeleteOptions) GetNamespace() string
func (*DeleteOptions) ProtoMessage ¶
func (*DeleteOptions) ProtoMessage()
func (*DeleteOptions) ProtoReflect ¶
func (x *DeleteOptions) ProtoReflect() protoreflect.Message
func (*DeleteOptions) Reset ¶
func (x *DeleteOptions) Reset()
func (*DeleteOptions) String ¶
func (x *DeleteOptions) String() string
type DeleteRequest ¶
type DeleteRequest struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Options *DeleteOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetOptions ¶
func (x *DeleteRequest) GetOptions() *DeleteOptions
func (*DeleteRequest) GetResource ¶
func (x *DeleteRequest) GetResource() *Resource
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct {
// contains filtered or unexported fields
}
func (*DeleteResponse) Descriptor
deprecated
func (*DeleteResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) ProtoReflect ¶
func (x *DeleteResponse) ProtoReflect() protoreflect.Message
func (*DeleteResponse) Reset ¶
func (x *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (x *DeleteResponse) String() string
type ListOptions ¶
type ListOptions struct { // namespace of the service Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ListOptions) Descriptor
deprecated
func (*ListOptions) Descriptor() ([]byte, []int)
Deprecated: Use ListOptions.ProtoReflect.Descriptor instead.
func (*ListOptions) GetNamespace ¶
func (x *ListOptions) GetNamespace() string
func (*ListOptions) ProtoMessage ¶
func (*ListOptions) ProtoMessage()
func (*ListOptions) ProtoReflect ¶
func (x *ListOptions) ProtoReflect() protoreflect.Message
func (*ListOptions) Reset ¶
func (x *ListOptions) Reset()
func (*ListOptions) String ¶
func (x *ListOptions) String() string
type ListRequest ¶
type ListRequest struct { Options *ListOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetOptions ¶
func (x *ListRequest) GetOptions() *ListOptions
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetServices ¶
func (x *ListResponse) GetServices() []*Service
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type LogRecord ¶
type LogRecord struct { // timestamp of log record Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // record metadata Metadata map[string]string `` /* 157-byte string literal not displayed */ // message Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*LogRecord) Descriptor
deprecated
func (*LogRecord) GetMessage ¶
func (*LogRecord) GetMetadata ¶
func (*LogRecord) GetTimestamp ¶
func (*LogRecord) ProtoMessage ¶
func (*LogRecord) ProtoMessage()
func (*LogRecord) ProtoReflect ¶
func (x *LogRecord) ProtoReflect() protoreflect.Message
type LogsOptions ¶
type LogsOptions struct { // namespace of the service Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*LogsOptions) Descriptor
deprecated
func (*LogsOptions) Descriptor() ([]byte, []int)
Deprecated: Use LogsOptions.ProtoReflect.Descriptor instead.
func (*LogsOptions) GetNamespace ¶
func (x *LogsOptions) GetNamespace() string
func (*LogsOptions) ProtoMessage ¶
func (*LogsOptions) ProtoMessage()
func (*LogsOptions) ProtoReflect ¶
func (x *LogsOptions) ProtoReflect() protoreflect.Message
func (*LogsOptions) Reset ¶
func (x *LogsOptions) Reset()
func (*LogsOptions) String ¶
func (x *LogsOptions) String() string
type LogsRequest ¶
type LogsRequest struct { // service to request logs for Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // stream records continuously Stream bool `protobuf:"varint,2,opt,name=stream,proto3" json:"stream,omitempty"` // count of records to request Count int64 `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"` // relative time in seconds // before the current time // from which to show logs Since int64 `protobuf:"varint,4,opt,name=since,proto3" json:"since,omitempty"` // options to use Options *LogsOptions `protobuf:"bytes,5,opt,name=options,proto3" json:"options,omitempty"` // service version Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"` // contains filtered or unexported fields }
func (*LogsRequest) Descriptor
deprecated
func (*LogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogsRequest.ProtoReflect.Descriptor instead.
func (*LogsRequest) GetCount ¶
func (x *LogsRequest) GetCount() int64
func (*LogsRequest) GetOptions ¶
func (x *LogsRequest) GetOptions() *LogsOptions
func (*LogsRequest) GetService ¶
func (x *LogsRequest) GetService() string
func (*LogsRequest) GetSince ¶
func (x *LogsRequest) GetSince() int64
func (*LogsRequest) GetStream ¶
func (x *LogsRequest) GetStream() bool
func (*LogsRequest) GetVersion ¶
func (x *LogsRequest) GetVersion() string
func (*LogsRequest) ProtoMessage ¶
func (*LogsRequest) ProtoMessage()
func (*LogsRequest) ProtoReflect ¶
func (x *LogsRequest) ProtoReflect() protoreflect.Message
func (*LogsRequest) Reset ¶
func (x *LogsRequest) Reset()
func (*LogsRequest) String ¶
func (x *LogsRequest) String() string
type Namespace ¶
type Namespace struct { // name of the namespace Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Namespace) Descriptor
deprecated
func (*Namespace) ProtoMessage ¶
func (*Namespace) ProtoMessage()
func (*Namespace) ProtoReflect ¶
func (x *Namespace) ProtoReflect() protoreflect.Message
type NetworkPolicy ¶
type NetworkPolicy struct { // the labels allowed ingress by this policy Allowedlabels map[string]string `` /* 167-byte string literal not displayed */ // name of the network policy Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // namespace the network policy belongs to Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*NetworkPolicy) Descriptor
deprecated
func (*NetworkPolicy) Descriptor() ([]byte, []int)
Deprecated: Use NetworkPolicy.ProtoReflect.Descriptor instead.
func (*NetworkPolicy) GetAllowedlabels ¶
func (x *NetworkPolicy) GetAllowedlabels() map[string]string
func (*NetworkPolicy) GetName ¶
func (x *NetworkPolicy) GetName() string
func (*NetworkPolicy) GetNamespace ¶
func (x *NetworkPolicy) GetNamespace() string
func (*NetworkPolicy) ProtoMessage ¶
func (*NetworkPolicy) ProtoMessage()
func (*NetworkPolicy) ProtoReflect ¶
func (x *NetworkPolicy) ProtoReflect() protoreflect.Message
func (*NetworkPolicy) Reset ¶
func (x *NetworkPolicy) Reset()
func (*NetworkPolicy) String ¶
func (x *NetworkPolicy) String() string
type ReadOptions ¶
type ReadOptions struct { // service name Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` // version of the service Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // type of service Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"` // namespace of the service Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*ReadOptions) Descriptor
deprecated
func (*ReadOptions) Descriptor() ([]byte, []int)
Deprecated: Use ReadOptions.ProtoReflect.Descriptor instead.
func (*ReadOptions) GetNamespace ¶
func (x *ReadOptions) GetNamespace() string
func (*ReadOptions) GetService ¶
func (x *ReadOptions) GetService() string
func (*ReadOptions) GetType ¶
func (x *ReadOptions) GetType() string
func (*ReadOptions) GetVersion ¶
func (x *ReadOptions) GetVersion() string
func (*ReadOptions) ProtoMessage ¶
func (*ReadOptions) ProtoMessage()
func (*ReadOptions) ProtoReflect ¶
func (x *ReadOptions) ProtoReflect() protoreflect.Message
func (*ReadOptions) Reset ¶
func (x *ReadOptions) Reset()
func (*ReadOptions) String ¶
func (x *ReadOptions) String() string
type ReadRequest ¶
type ReadRequest struct { Options *ReadOptions `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetOptions ¶
func (x *ReadRequest) GetOptions() *ReadOptions
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct { Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
func (*ReadResponse) Descriptor
deprecated
func (*ReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadResponse.ProtoReflect.Descriptor instead.
func (*ReadResponse) GetServices ¶
func (x *ReadResponse) GetServices() []*Service
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) ProtoReflect ¶
func (x *ReadResponse) ProtoReflect() protoreflect.Message
func (*ReadResponse) Reset ¶
func (x *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (x *ReadResponse) String() string
type Resource ¶
type Resource struct { Namespace *Namespace `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` Networkpolicy *NetworkPolicy `protobuf:"bytes,2,opt,name=networkpolicy,proto3" json:"networkpolicy,omitempty"` Service *Service `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"` Resourcequota *ResourceQuota `protobuf:"bytes,4,opt,name=resourcequota,proto3" json:"resourcequota,omitempty"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetNamespace ¶
func (*Resource) GetNetworkpolicy ¶
func (x *Resource) GetNetworkpolicy() *NetworkPolicy
func (*Resource) GetResourcequota ¶
func (x *Resource) GetResourcequota() *ResourceQuota
func (*Resource) GetService ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type ResourceQuota ¶
type ResourceQuota struct { // name of the resource quota Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // namespace the resource quota belongs to Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` // resource requests Requests *Resources `protobuf:"bytes,3,opt,name=requests,proto3" json:"requests,omitempty"` // resource limits Limits *Resources `protobuf:"bytes,4,opt,name=limits,proto3" json:"limits,omitempty"` // contains filtered or unexported fields }
func (*ResourceQuota) Descriptor
deprecated
func (*ResourceQuota) Descriptor() ([]byte, []int)
Deprecated: Use ResourceQuota.ProtoReflect.Descriptor instead.
func (*ResourceQuota) GetLimits ¶
func (x *ResourceQuota) GetLimits() *Resources
func (*ResourceQuota) GetName ¶
func (x *ResourceQuota) GetName() string
func (*ResourceQuota) GetNamespace ¶
func (x *ResourceQuota) GetNamespace() string
func (*ResourceQuota) GetRequests ¶
func (x *ResourceQuota) GetRequests() *Resources
func (*ResourceQuota) ProtoMessage ¶
func (*ResourceQuota) ProtoMessage()
func (*ResourceQuota) ProtoReflect ¶
func (x *ResourceQuota) ProtoReflect() protoreflect.Message
func (*ResourceQuota) Reset ¶
func (x *ResourceQuota) Reset()
func (*ResourceQuota) String ¶
func (x *ResourceQuota) String() string
type Resources ¶
type Resources struct { Memory int32 `protobuf:"varint,1,opt,name=Memory,proto3" json:"Memory,omitempty"` // in MiB CPU int32 `protobuf:"varint,2,opt,name=CPU,proto3" json:"CPU,omitempty"` // in millicores EphemeralStorage int32 `protobuf:"varint,3,opt,name=EphemeralStorage,proto3" json:"EphemeralStorage,omitempty"` // in MiB // contains filtered or unexported fields }
func (*Resources) Descriptor
deprecated
func (*Resources) GetEphemeralStorage ¶
func (*Resources) ProtoMessage ¶
func (*Resources) ProtoMessage()
func (*Resources) ProtoReflect ¶
func (x *Resources) ProtoReflect() protoreflect.Message
type RuntimeClient ¶
type RuntimeClient interface { Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*UpdateResponse, error) Logs(ctx context.Context, in *LogsRequest, opts ...grpc.CallOption) (Runtime_LogsClient, error) }
RuntimeClient is the client API for Runtime service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRuntimeClient ¶
func NewRuntimeClient(cc grpc.ClientConnInterface) RuntimeClient
type RuntimeHandler ¶
type RuntimeHandler interface { Create(context.Context, *CreateRequest, *CreateResponse) error Read(context.Context, *ReadRequest, *ReadResponse) error Delete(context.Context, *DeleteRequest, *DeleteResponse) error Update(context.Context, *UpdateRequest, *UpdateResponse) error Logs(context.Context, *LogsRequest, Runtime_LogsStream) error }
type RuntimeServer ¶
type RuntimeServer interface { Create(context.Context, *CreateRequest) (*CreateResponse, error) Read(context.Context, *ReadRequest) (*ReadResponse, error) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error) Update(context.Context, *UpdateRequest) (*UpdateResponse, error) Logs(*LogsRequest, Runtime_LogsServer) error // contains filtered or unexported methods }
RuntimeServer is the server API for Runtime service. All implementations must embed UnimplementedRuntimeServer for forward compatibility
type RuntimeService ¶
type RuntimeService interface { Create(ctx context.Context, in *CreateRequest, opts ...client.CallOption) (*CreateResponse, error) Read(ctx context.Context, in *ReadRequest, opts ...client.CallOption) (*ReadResponse, error) Delete(ctx context.Context, in *DeleteRequest, opts ...client.CallOption) (*DeleteResponse, error) Update(ctx context.Context, in *UpdateRequest, opts ...client.CallOption) (*UpdateResponse, error) Logs(ctx context.Context, in *LogsRequest, opts ...client.CallOption) (Runtime_LogsService, error) }
func NewRuntimeService ¶
func NewRuntimeService(name string, c client.Client) RuntimeService
type Runtime_LogsClient ¶
type Runtime_LogsClient interface { Recv() (*LogRecord, error) grpc.ClientStream }
type Runtime_LogsServer ¶
type Runtime_LogsServer interface { Send(*LogRecord) error grpc.ServerStream }
type Runtime_LogsService ¶
type Runtime_LogsStream ¶
type Service ¶
type Service struct { // name of the service Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // version of the service Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` // git url of the source Source string `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"` // service metadata Metadata map[string]string `` /* 157-byte string literal not displayed */ // status of the service Status int32 `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Service) Descriptor
deprecated
func (*Service) GetMetadata ¶
func (*Service) GetVersion ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type SourceClient ¶
type SourceClient interface {
Upload(ctx context.Context, opts ...grpc.CallOption) (Source_UploadClient, error)
}
SourceClient is the client API for Source service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSourceClient ¶
func NewSourceClient(cc grpc.ClientConnInterface) SourceClient
type SourceHandler ¶
type SourceHandler interface {
Upload(context.Context, Source_UploadStream) error
}
type SourceServer ¶
type SourceServer interface { Upload(Source_UploadServer) error // contains filtered or unexported methods }
SourceServer is the server API for Source service. All implementations must embed UnimplementedSourceServer for forward compatibility
type SourceService ¶
type SourceService interface {
Upload(ctx context.Context, opts ...client.CallOption) (Source_UploadService, error)
}
func NewSourceService ¶
func NewSourceService(name string, c client.Client) SourceService
type Source_UploadClient ¶
type Source_UploadClient interface { Send(*UploadRequest) error CloseAndRecv() (*UploadResponse, error) grpc.ClientStream }
type Source_UploadServer ¶
type Source_UploadServer interface { SendAndClose(*UploadResponse) error Recv() (*UploadRequest, error) grpc.ServerStream }
type Source_UploadService ¶
type Source_UploadService interface { Context() context.Context SendMsg(interface{}) error RecvMsg(interface{}) error CloseAndRecv() (*UploadResponse, error) Send(*UploadRequest) error }
type Source_UploadStream ¶
type Source_UploadStream interface { Context() context.Context SendMsg(interface{}) error RecvMsg(interface{}) error SendAndClose(*UploadResponse) error Recv() (*UploadRequest, error) }
type UnimplementedBuildServer ¶
type UnimplementedBuildServer struct { }
UnimplementedBuildServer must be embedded to have forward compatible implementations.
func (UnimplementedBuildServer) Read ¶
func (UnimplementedBuildServer) Read(*Service, Build_ReadServer) error
type UnimplementedRuntimeServer ¶
type UnimplementedRuntimeServer struct { }
UnimplementedRuntimeServer must be embedded to have forward compatible implementations.
func (UnimplementedRuntimeServer) Create ¶
func (UnimplementedRuntimeServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)
func (UnimplementedRuntimeServer) Delete ¶
func (UnimplementedRuntimeServer) Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
func (UnimplementedRuntimeServer) Logs ¶
func (UnimplementedRuntimeServer) Logs(*LogsRequest, Runtime_LogsServer) error
func (UnimplementedRuntimeServer) Read ¶
func (UnimplementedRuntimeServer) Read(context.Context, *ReadRequest) (*ReadResponse, error)
func (UnimplementedRuntimeServer) Update ¶
func (UnimplementedRuntimeServer) Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
type UnimplementedSourceServer ¶
type UnimplementedSourceServer struct { }
UnimplementedSourceServer must be embedded to have forward compatible implementations.
func (UnimplementedSourceServer) Upload ¶
func (UnimplementedSourceServer) Upload(Source_UploadServer) error
type UnsafeBuildServer ¶ added in v3.10.4
type UnsafeBuildServer interface {
// contains filtered or unexported methods
}
UnsafeBuildServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to BuildServer will result in compilation errors.
type UnsafeRuntimeServer ¶ added in v3.10.4
type UnsafeRuntimeServer interface {
// contains filtered or unexported methods
}
UnsafeRuntimeServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RuntimeServer will result in compilation errors.
type UnsafeSourceServer ¶ added in v3.10.4
type UnsafeSourceServer interface {
// contains filtered or unexported methods
}
UnsafeSourceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SourceServer will result in compilation errors.
type UpdateOptions ¶
type UpdateOptions struct { // namespace of the service Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"` // entrypoint within the source Entrypoint string `protobuf:"bytes,2,opt,name=entrypoint,proto3" json:"entrypoint,omitempty"` // number of instances Instances int64 `protobuf:"varint,3,opt,name=instances,proto3" json:"instances,omitempty"` // contains filtered or unexported fields }
func (*UpdateOptions) Descriptor
deprecated
func (*UpdateOptions) Descriptor() ([]byte, []int)
Deprecated: Use UpdateOptions.ProtoReflect.Descriptor instead.
func (*UpdateOptions) GetEntrypoint ¶
func (x *UpdateOptions) GetEntrypoint() string
func (*UpdateOptions) GetInstances ¶
func (x *UpdateOptions) GetInstances() int64
func (*UpdateOptions) GetNamespace ¶
func (x *UpdateOptions) GetNamespace() string
func (*UpdateOptions) ProtoMessage ¶
func (*UpdateOptions) ProtoMessage()
func (*UpdateOptions) ProtoReflect ¶
func (x *UpdateOptions) ProtoReflect() protoreflect.Message
func (*UpdateOptions) Reset ¶
func (x *UpdateOptions) Reset()
func (*UpdateOptions) String ¶
func (x *UpdateOptions) String() string
type UpdateRequest ¶
type UpdateRequest struct { Resource *Resource `protobuf:"bytes,1,opt,name=resource,proto3" json:"resource,omitempty"` Options *UpdateOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetOptions ¶
func (x *UpdateRequest) GetOptions() *UpdateOptions
func (*UpdateRequest) GetResource ¶
func (x *UpdateRequest) GetResource() *Resource
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶
type UpdateResponse struct {
// contains filtered or unexported fields
}
func (*UpdateResponse) Descriptor
deprecated
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string
type UploadRequest ¶
type UploadRequest struct { Service *Service `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
func (*UploadRequest) Descriptor
deprecated
func (*UploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use UploadRequest.ProtoReflect.Descriptor instead.
func (*UploadRequest) GetData ¶
func (x *UploadRequest) GetData() []byte
func (*UploadRequest) GetService ¶
func (x *UploadRequest) GetService() *Service
func (*UploadRequest) ProtoMessage ¶
func (*UploadRequest) ProtoMessage()
func (*UploadRequest) ProtoReflect ¶
func (x *UploadRequest) ProtoReflect() protoreflect.Message
func (*UploadRequest) Reset ¶
func (x *UploadRequest) Reset()
func (*UploadRequest) String ¶
func (x *UploadRequest) String() string
type UploadResponse ¶
type UploadResponse struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*UploadResponse) Descriptor
deprecated
func (*UploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use UploadResponse.ProtoReflect.Descriptor instead.
func (*UploadResponse) GetId ¶
func (x *UploadResponse) GetId() string
func (*UploadResponse) ProtoMessage ¶
func (*UploadResponse) ProtoMessage()
func (*UploadResponse) ProtoReflect ¶
func (x *UploadResponse) ProtoReflect() protoreflect.Message
func (*UploadResponse) Reset ¶
func (x *UploadResponse) Reset()
func (*UploadResponse) String ¶
func (x *UploadResponse) String() string