minion

package
v0.0.0-...-5984036 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var LicenseTerms_LicenseType_name = map[int32]string{
	0: "CUSTOMER",
	1: "TRIAL",
}
View Source 
var LicenseTerms_LicenseType_value = map[string]int32{
	"CUSTOMER": 0,
	"TRIAL":    1,
}

Functions

func RegisterKeldaServer 

func RegisterKeldaServer(s *grpc.Server, srv KeldaServer)

Types

type ContainerUpdate 

type ContainerUpdate struct {
	ControllerName       string   `protobuf:"bytes,1,opt,name=controller_name,json=controllerName,proto3" json:"controller_name,omitempty"`
	ContainerName        string   `protobuf:"bytes,2,opt,name=container_name,json=containerName,proto3" json:"container_name,omitempty"`
	OldDigest            string   `protobuf:"bytes,3,opt,name=old_digest,json=oldDigest,proto3" json:"old_digest,omitempty"`
	NewDigest            string   `protobuf:"bytes,4,opt,name=new_digest,json=newDigest,proto3" json:"new_digest,omitempty"`
	ImageUrl             string   `protobuf:"bytes,5,opt,name=image_url,json=imageUrl,proto3" json:"image_url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerUpdate) Descriptor 

func (*ContainerUpdate) Descriptor() ([]byte, []int)

func (*ContainerUpdate) GetContainerName 

func (m *ContainerUpdate) GetContainerName() string

func (*ContainerUpdate) GetControllerName 

func (m *ContainerUpdate) GetControllerName() string

func (*ContainerUpdate) GetImageUrl 

func (m *ContainerUpdate) GetImageUrl() string

func (*ContainerUpdate) GetNewDigest 

func (m *ContainerUpdate) GetNewDigest() string

func (*ContainerUpdate) GetOldDigest 

func (m *ContainerUpdate) GetOldDigest() string

func (*ContainerUpdate) ProtoMessage 

func (*ContainerUpdate) ProtoMessage()

func (*ContainerUpdate) Reset 

func (m *ContainerUpdate) Reset()

func (*ContainerUpdate) String 

func (m *ContainerUpdate) String() string

func (*ContainerUpdate) XXX_DiscardUnknown 

func (m *ContainerUpdate) XXX_DiscardUnknown()

func (*ContainerUpdate) XXX_Marshal 

func (m *ContainerUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerUpdate) XXX_Merge 

func (m *ContainerUpdate) XXX_Merge(src proto.Message)

func (*ContainerUpdate) XXX_Size 

func (m *ContainerUpdate) XXX_Size() int

func (*ContainerUpdate) XXX_Unmarshal 

func (m *ContainerUpdate) XXX_Unmarshal(b []byte) error

type CreateWorkspaceRequest 

type CreateWorkspaceRequest struct {
	Workspace            *Workspace `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*CreateWorkspaceRequest) Descriptor 

func (*CreateWorkspaceRequest) Descriptor() ([]byte, []int)

func (*CreateWorkspaceRequest) GetWorkspace 

func (m *CreateWorkspaceRequest) GetWorkspace() *Workspace

func (*CreateWorkspaceRequest) ProtoMessage 

func (*CreateWorkspaceRequest) ProtoMessage()

func (*CreateWorkspaceRequest) Reset 

func (m *CreateWorkspaceRequest) Reset()

func (*CreateWorkspaceRequest) String 

func (m *CreateWorkspaceRequest) String() string

func (*CreateWorkspaceRequest) XXX_DiscardUnknown 

func (m *CreateWorkspaceRequest) XXX_DiscardUnknown()

func (*CreateWorkspaceRequest) XXX_Marshal 

func (m *CreateWorkspaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkspaceRequest) XXX_Merge 

func (m *CreateWorkspaceRequest) XXX_Merge(src proto.Message)

func (*CreateWorkspaceRequest) XXX_Size 

func (m *CreateWorkspaceRequest) XXX_Size() int

func (*CreateWorkspaceRequest) XXX_Unmarshal 

func (m *CreateWorkspaceRequest) XXX_Unmarshal(b []byte) error

type CreateWorkspaceResponse 

type CreateWorkspaceResponse struct {
	Error                *errors.Error       `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	Messages             []*messages.Message `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*CreateWorkspaceResponse) Descriptor 

func (*CreateWorkspaceResponse) Descriptor() ([]byte, []int)

func (*CreateWorkspaceResponse) GetError 

func (m *CreateWorkspaceResponse) GetError() *errors.Error

func (*CreateWorkspaceResponse) GetMessages 

func (m *CreateWorkspaceResponse) GetMessages() []*messages.Message

func (*CreateWorkspaceResponse) ProtoMessage 

func (*CreateWorkspaceResponse) ProtoMessage()

func (*CreateWorkspaceResponse) Reset 

func (m *CreateWorkspaceResponse) Reset()

func (*CreateWorkspaceResponse) String 

func (m *CreateWorkspaceResponse) String() string

func (*CreateWorkspaceResponse) XXX_DiscardUnknown 

func (m *CreateWorkspaceResponse) XXX_DiscardUnknown()

func (*CreateWorkspaceResponse) XXX_Marshal 

func (m *CreateWorkspaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateWorkspaceResponse) XXX_Merge 

func (m *CreateWorkspaceResponse) XXX_Merge(src proto.Message)

func (*CreateWorkspaceResponse) XXX_Size 

func (m *CreateWorkspaceResponse) XXX_Size() int

func (*CreateWorkspaceResponse) XXX_Unmarshal 

func (m *CreateWorkspaceResponse) XXX_Unmarshal(b []byte) error

type Event 

type Event struct {
	Time                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Namespace            string               `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Event                string               `protobuf:"bytes,3,opt,name=event,proto3" json:"event,omitempty"`
	AdditionalJson       string               `protobuf:"bytes,4,opt,name=additional_json,json=additionalJson,proto3" json:"additional_json,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Event) Descriptor 

func (*Event) Descriptor() ([]byte, []int)

func (*Event) GetAdditionalJson 

func (m *Event) GetAdditionalJson() string

func (*Event) GetEvent 

func (m *Event) GetEvent() string

func (*Event) GetNamespace 

func (m *Event) GetNamespace() string

func (*Event) GetTime 

func (m *Event) GetTime() *timestamp.Timestamp

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Event) XXX_Merge 

func (m *Event) XXX_Merge(src proto.Message)

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

func (m *Event) XXX_Unmarshal(b []byte) error

type GetLicenseRequest 

type GetLicenseRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetLicenseRequest) Descriptor 

func (*GetLicenseRequest) Descriptor() ([]byte, []int)

func (*GetLicenseRequest) ProtoMessage 

func (*GetLicenseRequest) ProtoMessage()

func (*GetLicenseRequest) Reset 

func (m *GetLicenseRequest) Reset()

func (*GetLicenseRequest) String 

func (m *GetLicenseRequest) String() string

func (*GetLicenseRequest) XXX_DiscardUnknown 

func (m *GetLicenseRequest) XXX_DiscardUnknown()

func (*GetLicenseRequest) XXX_Marshal 

func (m *GetLicenseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLicenseRequest) XXX_Merge 

func (m *GetLicenseRequest) XXX_Merge(src proto.Message)

func (*GetLicenseRequest) XXX_Size 

func (m *GetLicenseRequest) XXX_Size() int

func (*GetLicenseRequest) XXX_Unmarshal 

func (m *GetLicenseRequest) XXX_Unmarshal(b []byte) error

type GetLicenseResponse 

type GetLicenseResponse struct {
	Error                *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	License              *License      `protobuf:"bytes,2,opt,name=license,proto3" json:"license,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetLicenseResponse) Descriptor 

func (*GetLicenseResponse) Descriptor() ([]byte, []int)

func (*GetLicenseResponse) GetError 

func (m *GetLicenseResponse) GetError() *errors.Error

func (*GetLicenseResponse) GetLicense 

func (m *GetLicenseResponse) GetLicense() *License

func (*GetLicenseResponse) ProtoMessage 

func (*GetLicenseResponse) ProtoMessage()

func (*GetLicenseResponse) Reset 

func (m *GetLicenseResponse) Reset()

func (*GetLicenseResponse) String 

func (m *GetLicenseResponse) String() string

func (*GetLicenseResponse) XXX_DiscardUnknown 

func (m *GetLicenseResponse) XXX_DiscardUnknown()

func (*GetLicenseResponse) XXX_Marshal 

func (m *GetLicenseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetLicenseResponse) XXX_Merge 

func (m *GetLicenseResponse) XXX_Merge(src proto.Message)

func (*GetLicenseResponse) XXX_Size 

func (m *GetLicenseResponse) XXX_Size() int

func (*GetLicenseResponse) XXX_Unmarshal 

func (m *GetLicenseResponse) XXX_Unmarshal(b []byte) error

type GetUpdatesRequest 

type GetUpdatesRequest struct {
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This is how image update works in Kelda:

At the time the workspace is created (when the user types `kelda dev`), the minion server will retrieve all the digests of the images (not already present) referenced by the manifests and write them to a field in the MicroserviceSpec called ImageDigests. Afterwards, when the microservice is being deployed, the controller will inject the digests from ImageDigests to the actual PodSpecs, so the images being pulled by Kubernetes pods will be fixed to what are specified in ImageDigests.

When the user types `kelda update`, the CLI will make an RPC call, GetUpdates, to the minion server. The minion server will again retrieve all the digests, compare them to the ones in ImageDigests, and return any difference to the user. If the user confirms the updates, the CLI will make another RPC call, PerformUpdates, to the minion server, passing the same structure returned by GetUpdates. The server will update the ImageDigests with the new digests, and will trigger a redeploy in the microservice controller.

func (*GetUpdatesRequest) Descriptor 

func (*GetUpdatesRequest) Descriptor() ([]byte, []int)

func (*GetUpdatesRequest) GetNamespace 

func (m *GetUpdatesRequest) GetNamespace() string

func (*GetUpdatesRequest) ProtoMessage 

func (*GetUpdatesRequest) ProtoMessage()

func (*GetUpdatesRequest) Reset 

func (m *GetUpdatesRequest) Reset()

func (*GetUpdatesRequest) String 

func (m *GetUpdatesRequest) String() string

func (*GetUpdatesRequest) XXX_DiscardUnknown 

func (m *GetUpdatesRequest) XXX_DiscardUnknown()

func (*GetUpdatesRequest) XXX_Marshal 

func (m *GetUpdatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetUpdatesRequest) XXX_Merge 

func (m *GetUpdatesRequest) XXX_Merge(src proto.Message)

func (*GetUpdatesRequest) XXX_Size 

func (m *GetUpdatesRequest) XXX_Size() int

func (*GetUpdatesRequest) XXX_Unmarshal 

func (m *GetUpdatesRequest) XXX_Unmarshal(b []byte) error

type GetUpdatesResponse 

type GetUpdatesResponse struct {
	ServiceUpdates       []*ServiceUpdate `protobuf:"bytes,1,rep,name=service_updates,json=serviceUpdates,proto3" json:"service_updates,omitempty"`
	Error                *errors.Error    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetUpdatesResponse) Descriptor 

func (*GetUpdatesResponse) Descriptor() ([]byte, []int)

func (*GetUpdatesResponse) GetError 

func (m *GetUpdatesResponse) GetError() *errors.Error

func (*GetUpdatesResponse) GetServiceUpdates 

func (m *GetUpdatesResponse) GetServiceUpdates() []*ServiceUpdate

func (*GetUpdatesResponse) ProtoMessage 

func (*GetUpdatesResponse) ProtoMessage()

func (*GetUpdatesResponse) Reset 

func (m *GetUpdatesResponse) Reset()

func (*GetUpdatesResponse) String 

func (m *GetUpdatesResponse) String() string

func (*GetUpdatesResponse) XXX_DiscardUnknown 

func (m *GetUpdatesResponse) XXX_DiscardUnknown()

func (*GetUpdatesResponse) XXX_Marshal 

func (m *GetUpdatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetUpdatesResponse) XXX_Merge 

func (m *GetUpdatesResponse) XXX_Merge(src proto.Message)

func (*GetUpdatesResponse) XXX_Size 

func (m *GetUpdatesResponse) XXX_Size() int

func (*GetUpdatesResponse) XXX_Unmarshal 

func (m *GetUpdatesResponse) XXX_Unmarshal(b []byte) error

type GetVersionRequest 

type GetVersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVersionRequest) Descriptor 

func (*GetVersionRequest) Descriptor() ([]byte, []int)

func (*GetVersionRequest) ProtoMessage 

func (*GetVersionRequest) ProtoMessage()

func (*GetVersionRequest) Reset 

func (m *GetVersionRequest) Reset()

func (*GetVersionRequest) String 

func (m *GetVersionRequest) String() string

func (*GetVersionRequest) XXX_DiscardUnknown 

func (m *GetVersionRequest) XXX_DiscardUnknown()

func (*GetVersionRequest) XXX_Marshal 

func (m *GetVersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVersionRequest) XXX_Merge 

func (m *GetVersionRequest) XXX_Merge(src proto.Message)

func (*GetVersionRequest) XXX_Size 

func (m *GetVersionRequest) XXX_Size() int

func (*GetVersionRequest) XXX_Unmarshal 

func (m *GetVersionRequest) XXX_Unmarshal(b []byte) error

type GetVersionResponse 

type GetVersionResponse struct {
	KeldaVersion         *KeldaVersion `protobuf:"bytes,1,opt,name=kelda_version,json=keldaVersion,proto3" json:"kelda_version,omitempty"`
	Error                *errors.Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*GetVersionResponse) Descriptor 

func (*GetVersionResponse) Descriptor() ([]byte, []int)

func (*GetVersionResponse) GetError 

func (m *GetVersionResponse) GetError() *errors.Error

func (*GetVersionResponse) GetKeldaVersion 

func (m *GetVersionResponse) GetKeldaVersion() *KeldaVersion

func (*GetVersionResponse) ProtoMessage 

func (*GetVersionResponse) ProtoMessage()

func (*GetVersionResponse) Reset 

func (m *GetVersionResponse) Reset()

func (*GetVersionResponse) String 

func (m *GetVersionResponse) String() string

func (*GetVersionResponse) XXX_DiscardUnknown 

func (m *GetVersionResponse) XXX_DiscardUnknown()

func (*GetVersionResponse) XXX_Marshal 

func (m *GetVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVersionResponse) XXX_Merge 

func (m *GetVersionResponse) XXX_Merge(src proto.Message)

func (*GetVersionResponse) XXX_Size 

func (m *GetVersionResponse) XXX_Size() int

func (*GetVersionResponse) XXX_Unmarshal 

func (m *GetVersionResponse) XXX_Unmarshal(b []byte) error

type KeldaClient 

type KeldaClient interface {
	CreateWorkspace(ctx context.Context, in *CreateWorkspaceRequest, opts ...grpc.CallOption) (*CreateWorkspaceResponse, error)
	LogEvent(ctx context.Context, in *LogEventRequest, opts ...grpc.CallOption) (*LogEventResponse, error)
	GetLicense(ctx context.Context, in *GetLicenseRequest, opts ...grpc.CallOption) (*GetLicenseResponse, error)
	GetVersion(ctx context.Context, in *GetVersionRequest, opts ...grpc.CallOption) (*GetVersionResponse, error)
	GetUpdates(ctx context.Context, in *GetUpdatesRequest, opts ...grpc.CallOption) (*GetUpdatesResponse, error)
	PerformUpdates(ctx context.Context, in *PerformUpdatesRequest, opts ...grpc.CallOption) (*PerformUpdatesResponse, error)
}

KeldaClient is the client API for Kelda service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewKeldaClient 

func NewKeldaClient(cc *grpc.ClientConn) KeldaClient

type KeldaServer 

type KeldaServer interface {
	CreateWorkspace(context.Context, *CreateWorkspaceRequest) (*CreateWorkspaceResponse, error)
	LogEvent(context.Context, *LogEventRequest) (*LogEventResponse, error)
	GetLicense(context.Context, *GetLicenseRequest) (*GetLicenseResponse, error)
	GetVersion(context.Context, *GetVersionRequest) (*GetVersionResponse, error)
	GetUpdates(context.Context, *GetUpdatesRequest) (*GetUpdatesResponse, error)
	PerformUpdates(context.Context, *PerformUpdatesRequest) (*PerformUpdatesResponse, error)
}

KeldaServer is the server API for Kelda service.

type KeldaVersion 

type KeldaVersion struct {
	Version              string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KeldaVersion) Descriptor 

func (*KeldaVersion) Descriptor() ([]byte, []int)

func (*KeldaVersion) GetVersion 

func (m *KeldaVersion) GetVersion() string

func (*KeldaVersion) ProtoMessage 

func (*KeldaVersion) ProtoMessage()

func (*KeldaVersion) Reset 

func (m *KeldaVersion) Reset()

func (*KeldaVersion) String 

func (m *KeldaVersion) String() string

func (*KeldaVersion) XXX_DiscardUnknown 

func (m *KeldaVersion) XXX_DiscardUnknown()

func (*KeldaVersion) XXX_Marshal 

func (m *KeldaVersion) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*KeldaVersion) XXX_Merge 

func (m *KeldaVersion) XXX_Merge(src proto.Message)

func (*KeldaVersion) XXX_Size 

func (m *KeldaVersion) XXX_Size() int

func (*KeldaVersion) XXX_Unmarshal 

func (m *KeldaVersion) XXX_Unmarshal(b []byte) error

type License 

type License struct {
	Terms                *LicenseTerms `protobuf:"bytes,1,opt,name=terms,proto3" json:"terms,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*License) Descriptor 

func (*License) Descriptor() ([]byte, []int)

func (*License) GetTerms 

func (m *License) GetTerms() *LicenseTerms

func (*License) ProtoMessage 

func (*License) ProtoMessage()

func (*License) Reset 

func (m *License) Reset()

func (*License) String 

func (m *License) String() string

func (*License) XXX_DiscardUnknown 

func (m *License) XXX_DiscardUnknown()

func (*License) XXX_Marshal 

func (m *License) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*License) XXX_Merge 

func (m *License) XXX_Merge(src proto.Message)

func (*License) XXX_Size 

func (m *License) XXX_Size() int

func (*License) XXX_Unmarshal 

func (m *License) XXX_Unmarshal(b []byte) error

type LicenseTerms 

type LicenseTerms struct {
	Customer             string                   `protobuf:"bytes,1,opt,name=customer,proto3" json:"customer,omitempty"`
	Type                 LicenseTerms_LicenseType `protobuf:"varint,2,opt,name=type,proto3,enum=kelda.minion.v0.LicenseTerms_LicenseType" json:"type,omitempty"`
	Seats                int32                    `protobuf:"varint,3,opt,name=seats,proto3" json:"seats,omitempty"`
	ExpiryTime           *timestamp.Timestamp     `protobuf:"bytes,4,opt,name=expiryTime,proto3" json:"expiryTime,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*LicenseTerms) Descriptor 

func (*LicenseTerms) Descriptor() ([]byte, []int)

func (*LicenseTerms) GetCustomer 

func (m *LicenseTerms) GetCustomer() string

func (*LicenseTerms) GetExpiryTime 

func (m *LicenseTerms) GetExpiryTime() *timestamp.Timestamp

func (*LicenseTerms) GetSeats 

func (m *LicenseTerms) GetSeats() int32

func (*LicenseTerms) GetType 

func (m *LicenseTerms) GetType() LicenseTerms_LicenseType

func (*LicenseTerms) ProtoMessage 

func (*LicenseTerms) ProtoMessage()

func (*LicenseTerms) Reset 

func (m *LicenseTerms) Reset()

func (*LicenseTerms) String 

func (m *LicenseTerms) String() string

func (*LicenseTerms) XXX_DiscardUnknown 

func (m *LicenseTerms) XXX_DiscardUnknown()

func (*LicenseTerms) XXX_Marshal 

func (m *LicenseTerms) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LicenseTerms) XXX_Merge 

func (m *LicenseTerms) XXX_Merge(src proto.Message)

func (*LicenseTerms) XXX_Size 

func (m *LicenseTerms) XXX_Size() int

func (*LicenseTerms) XXX_Unmarshal 

func (m *LicenseTerms) XXX_Unmarshal(b []byte) error

type LicenseTerms_LicenseType 

type LicenseTerms_LicenseType int32
const (
	LicenseTerms_CUSTOMER LicenseTerms_LicenseType = 0
	LicenseTerms_TRIAL    LicenseTerms_LicenseType = 1
)

func (LicenseTerms_LicenseType) EnumDescriptor 

func (LicenseTerms_LicenseType) EnumDescriptor() ([]byte, []int)

func (LicenseTerms_LicenseType) String 

func (x LicenseTerms_LicenseType) String() string

type LogEventRequest 

type LogEventRequest struct {
	Event                *Event   `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LogEventRequest) Descriptor 

func (*LogEventRequest) Descriptor() ([]byte, []int)

func (*LogEventRequest) GetEvent 

func (m *LogEventRequest) GetEvent() *Event

func (*LogEventRequest) ProtoMessage 

func (*LogEventRequest) ProtoMessage()

func (*LogEventRequest) Reset 

func (m *LogEventRequest) Reset()

func (*LogEventRequest) String 

func (m *LogEventRequest) String() string

func (*LogEventRequest) XXX_DiscardUnknown 

func (m *LogEventRequest) XXX_DiscardUnknown()

func (*LogEventRequest) XXX_Marshal 

func (m *LogEventRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEventRequest) XXX_Merge 

func (m *LogEventRequest) XXX_Merge(src proto.Message)

func (*LogEventRequest) XXX_Size 

func (m *LogEventRequest) XXX_Size() int

func (*LogEventRequest) XXX_Unmarshal 

func (m *LogEventRequest) XXX_Unmarshal(b []byte) error

type LogEventResponse 

type LogEventResponse struct {
	Error                *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*LogEventResponse) Descriptor 

func (*LogEventResponse) Descriptor() ([]byte, []int)

func (*LogEventResponse) GetError 

func (m *LogEventResponse) GetError() *errors.Error

func (*LogEventResponse) ProtoMessage 

func (*LogEventResponse) ProtoMessage()

func (*LogEventResponse) Reset 

func (m *LogEventResponse) Reset()

func (*LogEventResponse) String 

func (m *LogEventResponse) String() string

func (*LogEventResponse) XXX_DiscardUnknown 

func (m *LogEventResponse) XXX_DiscardUnknown()

func (*LogEventResponse) XXX_Marshal 

func (m *LogEventResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogEventResponse) XXX_Merge 

func (m *LogEventResponse) XXX_Merge(src proto.Message)

func (*LogEventResponse) XXX_Size 

func (m *LogEventResponse) XXX_Size() int

func (*LogEventResponse) XXX_Unmarshal 

func (m *LogEventResponse) XXX_Unmarshal(b []byte) error

type PerformUpdatesRequest 

type PerformUpdatesRequest struct {
	Namespace            string           `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	ServiceUpdates       []*ServiceUpdate `protobuf:"bytes,2,rep,name=service_updates,json=serviceUpdates,proto3" json:"service_updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PerformUpdatesRequest) Descriptor 

func (*PerformUpdatesRequest) Descriptor() ([]byte, []int)

func (*PerformUpdatesRequest) GetNamespace 

func (m *PerformUpdatesRequest) GetNamespace() string

func (*PerformUpdatesRequest) GetServiceUpdates 

func (m *PerformUpdatesRequest) GetServiceUpdates() []*ServiceUpdate

func (*PerformUpdatesRequest) ProtoMessage 

func (*PerformUpdatesRequest) ProtoMessage()

func (*PerformUpdatesRequest) Reset 

func (m *PerformUpdatesRequest) Reset()

func (*PerformUpdatesRequest) String 

func (m *PerformUpdatesRequest) String() string

func (*PerformUpdatesRequest) XXX_DiscardUnknown 

func (m *PerformUpdatesRequest) XXX_DiscardUnknown()

func (*PerformUpdatesRequest) XXX_Marshal 

func (m *PerformUpdatesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PerformUpdatesRequest) XXX_Merge 

func (m *PerformUpdatesRequest) XXX_Merge(src proto.Message)

func (*PerformUpdatesRequest) XXX_Size 

func (m *PerformUpdatesRequest) XXX_Size() int

func (*PerformUpdatesRequest) XXX_Unmarshal 

func (m *PerformUpdatesRequest) XXX_Unmarshal(b []byte) error

type PerformUpdatesResponse 

type PerformUpdatesResponse struct {
	Error                *errors.Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*PerformUpdatesResponse) Descriptor 

func (*PerformUpdatesResponse) Descriptor() ([]byte, []int)

func (*PerformUpdatesResponse) GetError 

func (m *PerformUpdatesResponse) GetError() *errors.Error

func (*PerformUpdatesResponse) ProtoMessage 

func (*PerformUpdatesResponse) ProtoMessage()

func (*PerformUpdatesResponse) Reset 

func (m *PerformUpdatesResponse) Reset()

func (*PerformUpdatesResponse) String 

func (m *PerformUpdatesResponse) String() string

func (*PerformUpdatesResponse) XXX_DiscardUnknown 

func (m *PerformUpdatesResponse) XXX_DiscardUnknown()

func (*PerformUpdatesResponse) XXX_Marshal 

func (m *PerformUpdatesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PerformUpdatesResponse) XXX_Merge 

func (m *PerformUpdatesResponse) XXX_Merge(src proto.Message)

func (*PerformUpdatesResponse) XXX_Size 

func (m *PerformUpdatesResponse) XXX_Size() int

func (*PerformUpdatesResponse) XXX_Unmarshal 

func (m *PerformUpdatesResponse) XXX_Unmarshal(b []byte) error

type Service 

type Service struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Manifests            []string `protobuf:"bytes,2,rep,name=manifests,proto3" json:"manifests,omitempty"`
	DevMode              bool     `protobuf:"varint,3,opt,name=dev_mode,json=devMode,proto3" json:"dev_mode,omitempty"`
	DevImage             string   `protobuf:"bytes,4,opt,name=dev_image,json=devImage,proto3" json:"dev_image,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Service contains the configuration required to boot a Microservice.

func (*Service) Descriptor 

func (*Service) Descriptor() ([]byte, []int)

func (*Service) GetDevImage 

func (m *Service) GetDevImage() string

func (*Service) GetDevMode 

func (m *Service) GetDevMode() bool

func (*Service) GetManifests 

func (m *Service) GetManifests() []string

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceUpdate 

type ServiceUpdate struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContainerUpdates     []*ContainerUpdate `protobuf:"bytes,2,rep,name=container_updates,json=containerUpdates,proto3" json:"container_updates,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*ServiceUpdate) Descriptor 

func (*ServiceUpdate) Descriptor() ([]byte, []int)

func (*ServiceUpdate) GetContainerUpdates 

func (m *ServiceUpdate) GetContainerUpdates() []*ContainerUpdate

func (*ServiceUpdate) GetName 

func (m *ServiceUpdate) GetName() string

func (*ServiceUpdate) ProtoMessage 

func (*ServiceUpdate) ProtoMessage()

func (*ServiceUpdate) Reset 

func (m *ServiceUpdate) Reset()

func (*ServiceUpdate) String 

func (m *ServiceUpdate) String() string

func (*ServiceUpdate) XXX_DiscardUnknown 

func (m *ServiceUpdate) XXX_DiscardUnknown()

func (*ServiceUpdate) XXX_Marshal 

func (m *ServiceUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceUpdate) XXX_Merge 

func (m *ServiceUpdate) XXX_Merge(src proto.Message)

func (*ServiceUpdate) XXX_Size 

func (m *ServiceUpdate) XXX_Size() int

func (*ServiceUpdate) XXX_Unmarshal 

func (m *ServiceUpdate) XXX_Unmarshal(b []byte) error

type Tunnel 

type Tunnel struct {
	ServiceName          string   `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	LocalPort            uint32   `protobuf:"varint,2,opt,name=local_port,json=localPort,proto3" json:"local_port,omitempty"`
	RemotePort           uint32   `protobuf:"varint,3,opt,name=remote_port,json=remotePort,proto3" json:"remote_port,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Tunnel defines a desired tunnel between a local port and a service in the development environment.

func (*Tunnel) Descriptor 

func (*Tunnel) Descriptor() ([]byte, []int)

func (*Tunnel) GetLocalPort 

func (m *Tunnel) GetLocalPort() uint32

func (*Tunnel) GetRemotePort 

func (m *Tunnel) GetRemotePort() uint32

func (*Tunnel) GetServiceName 

func (m *Tunnel) GetServiceName() string

func (*Tunnel) ProtoMessage 

func (*Tunnel) ProtoMessage()

func (*Tunnel) Reset 

func (m *Tunnel) Reset()

func (*Tunnel) String 

func (m *Tunnel) String() string

func (*Tunnel) XXX_DiscardUnknown 

func (m *Tunnel) XXX_DiscardUnknown()

func (*Tunnel) XXX_Marshal 

func (m *Tunnel) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Tunnel) XXX_Merge 

func (m *Tunnel) XXX_Merge(src proto.Message)

func (*Tunnel) XXX_Size 

func (m *Tunnel) XXX_Size() int

func (*Tunnel) XXX_Unmarshal 

func (m *Tunnel) XXX_Unmarshal(b []byte) error

type Workspace 

type Workspace struct {
	Namespace            string     `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Services             []*Service `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"`
	Tunnels              []*Tunnel  `protobuf:"bytes,3,rep,name=tunnels,proto3" json:"tunnels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Workspace contains the main development environment configuration.

func (*Workspace) Descriptor 

func (*Workspace) Descriptor() ([]byte, []int)

func (*Workspace) GetNamespace 

func (m *Workspace) GetNamespace() string

func (*Workspace) GetServices 

func (m *Workspace) GetServices() []*Service

func (*Workspace) GetTunnels 

func (m *Workspace) GetTunnels() []*Tunnel

func (*Workspace) ProtoMessage 

func (*Workspace) ProtoMessage()

func (*Workspace) Reset 

func (m *Workspace) Reset()

func (*Workspace) String 

func (m *Workspace) String() string

func (*Workspace) XXX_DiscardUnknown 

func (m *Workspace) XXX_DiscardUnknown()

func (*Workspace) XXX_Marshal 

func (m *Workspace) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Workspace) XXX_Merge 

func (m *Workspace) XXX_Merge(src proto.Message)

func (*Workspace) XXX_Size 

func (m *Workspace) XXX_Size() int

func (*Workspace) XXX_Unmarshal 

func (m *Workspace) XXX_Unmarshal(b []byte) error

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.