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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL