runtime

package
v3.10.5 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2022 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)

View Source 
var File_proto_runtime_runtime_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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 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 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_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"`
	// 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) 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 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_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 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

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.