runtime

package
v0.0.0-...-5e24cfe Latest Latest
Warning

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

 Go to latest Published: Dec 3, 2021 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_runtime_proto protoreflect.FileDescriptor

Functions

func NewBuildEndpoints 

func NewBuildEndpoints() []*api.Endpoint

func NewRuntimeEndpoints 

func NewRuntimeEndpoints() []*api.Endpoint

func NewSourceEndpoints 

func NewSourceEndpoints() []*api.Endpoint

func RegisterBuildHandler 

func RegisterBuildHandler(s server.Server, hdlr BuildHandler, opts ...server.HandlerOption) error

func RegisterRuntimeHandler 

func RegisterRuntimeHandler(s server.Server, hdlr RuntimeHandler, opts ...server.HandlerOption) error

func RegisterSourceHandler 

func RegisterSourceHandler(s server.Server, hdlr SourceHandler, opts ...server.HandlerOption) error

Types

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 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_ReadService 

type Build_ReadService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*BuildReadResponse, error)
}

type Build_ReadStream 

type Build_ReadStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*BuildReadResponse) error
}

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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use LogRecord.ProtoReflect.Descriptor instead.

func (*LogRecord) GetMessage 

func (x *LogRecord) GetMessage() string

func (*LogRecord) GetMetadata 

func (x *LogRecord) GetMetadata() map[string]string

func (*LogRecord) GetTimestamp 

func (x *LogRecord) GetTimestamp() int64

func (*LogRecord) ProtoMessage 

func (*LogRecord) ProtoMessage()

func (*LogRecord) ProtoReflect 

func (x *LogRecord) ProtoReflect() protoreflect.Message

func (*LogRecord) Reset 

func (x *LogRecord) Reset()

func (*LogRecord) String 

func (x *LogRecord) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Namespace.ProtoReflect.Descriptor instead.

func (*Namespace) GetName 

func (x *Namespace) GetName() string

func (*Namespace) ProtoMessage 

func (*Namespace) ProtoMessage()

func (*Namespace) ProtoReflect 

func (x *Namespace) ProtoReflect() protoreflect.Message

func (*Namespace) Reset 

func (x *Namespace) Reset()

func (*Namespace) String 

func (x *Namespace) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetNamespace 

func (x *Resource) GetNamespace() *Namespace

func (*Resource) GetNetworkpolicy 

func (x *Resource) GetNetworkpolicy() *NetworkPolicy

func (*Resource) GetResourcequota 

func (x *Resource) GetResourcequota() *ResourceQuota

func (*Resource) GetService 

func (x *Resource) GetService() *Service

func (*Resource) ProtoMessage 

func (*Resource) ProtoMessage()

func (*Resource) ProtoReflect 

func (x *Resource) ProtoReflect() protoreflect.Message

func (*Resource) Reset 

func (x *Resource) Reset()

func (*Resource) String 

func (x *Resource) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Resources.ProtoReflect.Descriptor instead.

func (*Resources) GetCPU 

func (x *Resources) GetCPU() int32

func (*Resources) GetEphemeralStorage 

func (x *Resources) GetEphemeralStorage() int32

func (*Resources) GetMemory 

func (x *Resources) GetMemory() int32

func (*Resources) ProtoMessage 

func (*Resources) ProtoMessage()

func (*Resources) ProtoReflect 

func (x *Resources) ProtoReflect() protoreflect.Message

func (*Resources) Reset 

func (x *Resources) Reset()

func (*Resources) String 

func (x *Resources) String() string

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 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_LogsService 

type Runtime_LogsService interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*LogRecord, error)
}

type Runtime_LogsStream 

type Runtime_LogsStream interface {
	Context() context.Context
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*LogRecord) error
}

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) Descriptor() ([]byte, []int)

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetMetadata 

func (x *Service) GetMetadata() map[string]string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetSource 

func (x *Service) GetSource() string

func (*Service) GetStatus 

func (x *Service) GetStatus() int32

func (*Service) GetVersion 

func (x *Service) GetVersion() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

func (x *Service) ProtoReflect() protoreflect.Message

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type SourceHandler 

type SourceHandler interface {
	Upload(context.Context, Source_UploadStream) error
}

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_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 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

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.