v1

package
v0.0.4 Latest Latest
Warning

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

 Go to latest Published: Feb 12, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	FilterOp_name = map[int32]string{
		0: "OP_EQUALS",
		1: "OP_STARTS_WITH",
		2: "OP_ENDS_WITH",
		3: "OP_CONTAINS",
		4: "OP_EXISTS",
	}
	FilterOp_value = map[string]int32{
		"OP_EQUALS":      0,
		"OP_STARTS_WITH": 1,
		"OP_ENDS_WITH":   2,
		"OP_CONTAINS":    3,
		"OP_EXISTS":      4,
	}
)

Enum value maps for FilterOp.

View Source 
var (
	ListenRequestLogs_name = map[int32]string{
		0: "LOGS_DISABLED",
		1: "LOGS_UNSLICED",
		2: "LOGS_RAW",
		3: "LOGS_HTML",
	}
	ListenRequestLogs_value = map[string]int32{
		"LOGS_DISABLED": 0,
		"LOGS_UNSLICED": 1,
		"LOGS_RAW":      2,
		"LOGS_HTML":     3,
	}
)

Enum value maps for ListenRequestLogs.

View Source 
var (
	EngineTrigger_name = map[int32]string{
		0: "TRIGGER_UNKNOWN",
		1: "TRIGGER_MANUAL",
		2: "TRIGGER_PUSH",
		3: "TRIGGER_DELETED",
	}
	EngineTrigger_value = map[string]int32{
		"TRIGGER_UNKNOWN": 0,
		"TRIGGER_MANUAL":  1,
		"TRIGGER_PUSH":    2,
		"TRIGGER_DELETED": 3,
	}
)

Enum value maps for EngineTrigger.

View Source 
var (
	EnginePhase_name = map[int32]string{
		0: "PHASE_UNKNOWN",
		1: "PHASE_PREPARING",
		2: "PHASE_STARTING",
		3: "PHASE_RUNNING",
		4: "PHASE_DONE",
		5: "PHASE_CLEANUP",
		6: "PHASE_WAITING",
	}
	EnginePhase_value = map[string]int32{
		"PHASE_UNKNOWN":   0,
		"PHASE_PREPARING": 1,
		"PHASE_STARTING":  2,
		"PHASE_RUNNING":   3,
		"PHASE_DONE":      4,
		"PHASE_CLEANUP":   5,
		"PHASE_WAITING":   6,
	}
)

Enum value maps for EnginePhase.

View Source 
var (
	LogSliceType_name = map[int32]string{
		0: "SLICE_ABANDONED",
		1: "SLICE_PHASE",
		2: "SLICE_START",
		3: "SLICE_CONTENT",
		4: "SLICE_DONE",
		5: "SLICE_FAIL",
		6: "SLICE_RESULT",
	}
	LogSliceType_value = map[string]int32{
		"SLICE_ABANDONED": 0,
		"SLICE_PHASE":     1,
		"SLICE_START":     2,
		"SLICE_CONTENT":   3,
		"SLICE_DONE":      4,
		"SLICE_FAIL":      5,
		"SLICE_RESULT":    6,
	}
)

Enum value maps for LogSliceType.

View Source 
var CacheService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.CacheService",
	HandlerType: (*CacheServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartFromPreviousEngine",
			Handler:    _CacheService_StartFromPreviousEngine_Handler,
		},
		{
			MethodName: "StartEngine",
			Handler:    _CacheService_StartEngine_Handler,
		},
		{
			MethodName: "ListEngines",
			Handler:    _CacheService_ListEngines_Handler,
		},
		{
			MethodName: "GetEngine",
			Handler:    _CacheService_GetEngine_Handler,
		},
		{
			MethodName: "StopEngine",
			Handler:    _CacheService_StopEngine_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartLocalEngine",
			Handler:       _CacheService_StartLocalEngine_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _CacheService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _CacheService_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cache.proto",
}

CacheService_ServiceDesc is the grpc.ServiceDesc for CacheService 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 CacheUI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.CacheUI",
	HandlerType: (*CacheUIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReadOnly",
			Handler:    _CacheUI_IsReadOnly_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListEngineSpecs",
			Handler:       _CacheUI_ListEngineSpecs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "cache-ui.proto",
}

CacheUI_ServiceDesc is the grpc.ServiceDesc for CacheUI 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_cache_proto protoreflect.FileDescriptor
View Source 
var File_cache_ui_proto protoreflect.FileDescriptor

Functions

func RegisterCacheServiceServer 

func RegisterCacheServiceServer(s grpc.ServiceRegistrar, srv CacheServiceServer)

func RegisterCacheUIServer 

func RegisterCacheUIServer(s grpc.ServiceRegistrar, srv CacheUIServer)

Types

type Annotation 

type Annotation struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Annotation) Descriptor deprecated 

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

Deprecated: Use Annotation.ProtoReflect.Descriptor instead.

func (*Annotation) GetKey 

func (x *Annotation) GetKey() string

func (*Annotation) GetValue 

func (x *Annotation) GetValue() string

func (*Annotation) ProtoMessage 

func (*Annotation) ProtoMessage()

func (*Annotation) ProtoReflect 

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

func (*Annotation) Reset 

func (x *Annotation) Reset()

func (*Annotation) String 

func (x *Annotation) String() string

type CacheServiceClient 

type CacheServiceClient interface {
	// StartLocalEngine starts a Cache Engine on the Bhojpur.NET Platform directly.
	// The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the cache/config.yaml
	//   3. all bytes constituting the Engine YAML that will be executed (that the config.yaml points to)
	//   4. all bytes constituting the gzipped Bhojpur.NET Platform application tar stream
	//   5. the Bhojpur.NET Platform application tar stream done marker
	StartLocalEngine(ctx context.Context, opts ...grpc.CallOption) (CacheService_StartLocalEngineClient, error)
	// StartFromPreviousEngine starts a new Engine based on a previous one.
	// If the previous Engine does not have the can-replay condition set this call will result in an error.
	StartFromPreviousEngine(ctx context.Context, in *StartFromPreviousEngineRequest, opts ...grpc.CallOption) (*StartEngineResponse, error)
	// StartEngineRequest starts a new Engine based on its specification.
	StartEngine(ctx context.Context, in *StartEngineRequest, opts ...grpc.CallOption) (*StartEngineResponse, error)
	// Searches for Engine(s) known to this Engine
	ListEngines(ctx context.Context, in *ListEnginesRequest, opts ...grpc.CallOption) (*ListEnginesResponse, error)
	// Subscribe listens to new Engine(s) updates
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (CacheService_SubscribeClient, error)
	// GetEngine retrieves details of a single Engine
	GetEngine(ctx context.Context, in *GetEngineRequest, opts ...grpc.CallOption) (*GetEngineResponse, error)
	// Listen listens to Engine updates and log output of a running Engine
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (CacheService_ListenClient, error)
	// StopEngine stops a currently running Engine
	StopEngine(ctx context.Context, in *StopEngineRequest, opts ...grpc.CallOption) (*StopEngineResponse, error)
}

CacheServiceClient is the client API for CacheService 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 NewCacheServiceClient 

func NewCacheServiceClient(cc grpc.ClientConnInterface) CacheServiceClient

type CacheServiceServer 

type CacheServiceServer interface {
	// StartLocalEngine starts a Cache Engine on the Bhojpur.NET Platform directly.
	// The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the cache/config.yaml
	//   3. all bytes constituting the Engine YAML that will be executed (that the config.yaml points to)
	//   4. all bytes constituting the gzipped Bhojpur.NET Platform application tar stream
	//   5. the Bhojpur.NET Platform application tar stream done marker
	StartLocalEngine(CacheService_StartLocalEngineServer) error
	// StartFromPreviousEngine starts a new Engine based on a previous one.
	// If the previous Engine does not have the can-replay condition set this call will result in an error.
	StartFromPreviousEngine(context.Context, *StartFromPreviousEngineRequest) (*StartEngineResponse, error)
	// StartEngineRequest starts a new Engine based on its specification.
	StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)
	// Searches for Engine(s) known to this Engine
	ListEngines(context.Context, *ListEnginesRequest) (*ListEnginesResponse, error)
	// Subscribe listens to new Engine(s) updates
	Subscribe(*SubscribeRequest, CacheService_SubscribeServer) error
	// GetEngine retrieves details of a single Engine
	GetEngine(context.Context, *GetEngineRequest) (*GetEngineResponse, error)
	// Listen listens to Engine updates and log output of a running Engine
	Listen(*ListenRequest, CacheService_ListenServer) error
	// StopEngine stops a currently running Engine
	StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)
	// contains filtered or unexported methods
}

CacheServiceServer is the server API for CacheService service. All implementations must embed UnimplementedCacheServiceServer for forward compatibility

type CacheService_ListenClient 

type CacheService_ListenClient interface {
	Recv() (*ListenResponse, error)
	grpc.ClientStream
}

type CacheService_ListenServer 

type CacheService_ListenServer interface {
	Send(*ListenResponse) error
	grpc.ServerStream
}

type CacheService_StartLocalEngineClient 

type CacheService_StartLocalEngineClient interface {
	Send(*StartLocalEngineRequest) error
	CloseAndRecv() (*StartEngineResponse, error)
	grpc.ClientStream
}

type CacheService_StartLocalEngineServer 

type CacheService_StartLocalEngineServer interface {
	SendAndClose(*StartEngineResponse) error
	Recv() (*StartLocalEngineRequest, error)
	grpc.ServerStream
}

type CacheService_SubscribeClient 

type CacheService_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type CacheService_SubscribeServer 

type CacheService_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type CacheUIClient 

type CacheUIClient interface {
	// ListEngineSpecs returns a list of Cache Engine(s) that can be started through the UI.
	ListEngineSpecs(ctx context.Context, in *ListEngineSpecsRequest, opts ...grpc.CallOption) (CacheUI_ListEngineSpecsClient, error)
	// IsReadOnly returns true if the UI is readonly.
	IsReadOnly(ctx context.Context, in *IsReadOnlyRequest, opts ...grpc.CallOption) (*IsReadOnlyResponse, error)
}

CacheUIClient is the client API for CacheUI 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 NewCacheUIClient 

func NewCacheUIClient(cc grpc.ClientConnInterface) CacheUIClient

type CacheUIServer 

type CacheUIServer interface {
	// ListEngineSpecs returns a list of Cache Engine(s) that can be started through the UI.
	ListEngineSpecs(*ListEngineSpecsRequest, CacheUI_ListEngineSpecsServer) error
	// IsReadOnly returns true if the UI is readonly.
	IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error)
	// contains filtered or unexported methods
}

CacheUIServer is the server API for CacheUI service. All implementations must embed UnimplementedCacheUIServer for forward compatibility

type CacheUI_ListEngineSpecsClient 

type CacheUI_ListEngineSpecsClient interface {
	Recv() (*ListEngineSpecsResponse, error)
	grpc.ClientStream
}

type CacheUI_ListEngineSpecsServer 

type CacheUI_ListEngineSpecsServer interface {
	Send(*ListEngineSpecsResponse) error
	grpc.ServerStream
}

type DesiredAnnotation 

type DesiredAnnotation struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Required    bool   `protobuf:"varint,2,opt,name=required,proto3" json:"required,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

DesiredAnnotation describes an annotation a Engine should have

func (*DesiredAnnotation) Descriptor deprecated 

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

Deprecated: Use DesiredAnnotation.ProtoReflect.Descriptor instead.

func (*DesiredAnnotation) GetDescription 

func (x *DesiredAnnotation) GetDescription() string

func (*DesiredAnnotation) GetName 

func (x *DesiredAnnotation) GetName() string

func (*DesiredAnnotation) GetRequired 

func (x *DesiredAnnotation) GetRequired() bool

func (*DesiredAnnotation) ProtoMessage 

func (*DesiredAnnotation) ProtoMessage()

func (*DesiredAnnotation) ProtoReflect 

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

func (*DesiredAnnotation) Reset 

func (x *DesiredAnnotation) Reset()

func (*DesiredAnnotation) String 

func (x *DesiredAnnotation) String() string

type EngineConditions 

type EngineConditions struct {
	Success      bool                   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	FailureCount int32                  `protobuf:"varint,2,opt,name=failure_count,json=failureCount,proto3" json:"failure_count,omitempty"`
	CanReplay    bool                   `protobuf:"varint,3,opt,name=can_replay,json=canReplay,proto3" json:"can_replay,omitempty"`
	WaitUntil    *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	DidExecute   bool                   `protobuf:"varint,5,opt,name=did_execute,json=didExecute,proto3" json:"did_execute,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineConditions) Descriptor deprecated 

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

Deprecated: Use EngineConditions.ProtoReflect.Descriptor instead.

func (*EngineConditions) GetCanReplay 

func (x *EngineConditions) GetCanReplay() bool

func (*EngineConditions) GetDidExecute 

func (x *EngineConditions) GetDidExecute() bool

func (*EngineConditions) GetFailureCount 

func (x *EngineConditions) GetFailureCount() int32

func (*EngineConditions) GetSuccess 

func (x *EngineConditions) GetSuccess() bool

func (*EngineConditions) GetWaitUntil 

func (x *EngineConditions) GetWaitUntil() *timestamppb.Timestamp

func (*EngineConditions) ProtoMessage 

func (*EngineConditions) ProtoMessage()

func (*EngineConditions) ProtoReflect 

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

func (*EngineConditions) Reset 

func (x *EngineConditions) Reset()

func (*EngineConditions) String 

func (x *EngineConditions) String() string

type EngineMetadata 

type EngineMetadata struct {
	Owner          string                 `protobuf:"bytes,1,opt,name=owner,proto3" json:"owner,omitempty"`
	Repository     *Repository            `protobuf:"bytes,2,opt,name=repository,proto3" json:"repository,omitempty"`
	Trigger        EngineTrigger          `protobuf:"varint,3,opt,name=trigger,proto3,enum=v1.EngineTrigger" json:"trigger,omitempty"`
	Created        *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
	Finished       *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=finished,proto3" json:"finished,omitempty"`
	Annotations    []*Annotation          `protobuf:"bytes,6,rep,name=annotations,proto3" json:"annotations,omitempty"`
	EngineSpecName string                 `protobuf:"bytes,7,opt,name=engine_spec_name,json=engineSpecName,proto3" json:"engine_spec_name,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineMetadata) Descriptor deprecated 

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

Deprecated: Use EngineMetadata.ProtoReflect.Descriptor instead.

func (*EngineMetadata) GetAnnotations 

func (x *EngineMetadata) GetAnnotations() []*Annotation

func (*EngineMetadata) GetCreated 

func (x *EngineMetadata) GetCreated() *timestamppb.Timestamp

func (*EngineMetadata) GetEngineSpecName 

func (x *EngineMetadata) GetEngineSpecName() string

func (*EngineMetadata) GetFinished 

func (x *EngineMetadata) GetFinished() *timestamppb.Timestamp

func (*EngineMetadata) GetOwner 

func (x *EngineMetadata) GetOwner() string

func (*EngineMetadata) GetRepository 

func (x *EngineMetadata) GetRepository() *Repository

func (*EngineMetadata) GetTrigger 

func (x *EngineMetadata) GetTrigger() EngineTrigger

func (*EngineMetadata) ProtoMessage 

func (*EngineMetadata) ProtoMessage()

func (*EngineMetadata) ProtoReflect 

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

func (*EngineMetadata) Reset 

func (x *EngineMetadata) Reset()

func (*EngineMetadata) String 

func (x *EngineMetadata) String() string

type EnginePhase 

type EnginePhase int32
const (
	// Unknown means we don't know what state the Engine is in
	EnginePhase_PHASE_UNKNOWN EnginePhase = 0
	// Preparing means the Engine hasn't started yet and isn't consuming resources in the system
	EnginePhase_PHASE_PREPARING EnginePhase = 1
	// Starting means the Engine has been scheduled and is waiting to run. Things that might prevent it
	// from running already are pod scheduling, image pull or container startup.
	EnginePhase_PHASE_STARTING EnginePhase = 2
	// Running means the Engine is actually running and doing work.
	EnginePhase_PHASE_RUNNING EnginePhase = 3
	// Done means the Engine has run and is finished
	EnginePhase_PHASE_DONE EnginePhase = 4
	// Cleaning means the Engine is in post-run cleanup
	EnginePhase_PHASE_CLEANUP EnginePhase = 5
	// Waiting means the Engine is waiting for its start time or some other condition to be met
	EnginePhase_PHASE_WAITING EnginePhase = 6
)

func (EnginePhase) Descriptor 

func (EnginePhase) Descriptor() protoreflect.EnumDescriptor

func (EnginePhase) Enum 

func (x EnginePhase) Enum() *EnginePhase

func (EnginePhase) EnumDescriptor deprecated 

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

Deprecated: Use EnginePhase.Descriptor instead.

func (EnginePhase) Number 

func (x EnginePhase) Number() protoreflect.EnumNumber

func (EnginePhase) String 

func (x EnginePhase) String() string

func (EnginePhase) Type 

func (EnginePhase) Type() protoreflect.EnumType

type EngineResult 

type EngineResult struct {
	Type        string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Payload     string   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Description string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Channels    []string `protobuf:"bytes,4,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineResult) Descriptor deprecated 

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

Deprecated: Use EngineResult.ProtoReflect.Descriptor instead.

func (*EngineResult) GetChannels 

func (x *EngineResult) GetChannels() []string

func (*EngineResult) GetDescription 

func (x *EngineResult) GetDescription() string

func (*EngineResult) GetPayload 

func (x *EngineResult) GetPayload() string

func (*EngineResult) GetType 

func (x *EngineResult) GetType() string

func (*EngineResult) ProtoMessage 

func (*EngineResult) ProtoMessage()

func (*EngineResult) ProtoReflect 

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

func (*EngineResult) Reset 

func (x *EngineResult) Reset()

func (*EngineResult) String 

func (x *EngineResult) String() string

type EngineStatus 

type EngineStatus struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Metadata   *EngineMetadata   `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Phase      EnginePhase       `protobuf:"varint,3,opt,name=phase,proto3,enum=v1.EnginePhase" json:"phase,omitempty"`
	Conditions *EngineConditions `protobuf:"bytes,4,opt,name=conditions,proto3" json:"conditions,omitempty"`
	Details    string            `protobuf:"bytes,5,opt,name=details,proto3" json:"details,omitempty"`
	Results    []*EngineResult   `protobuf:"bytes,6,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*EngineStatus) Descriptor deprecated 

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

Deprecated: Use EngineStatus.ProtoReflect.Descriptor instead.

func (*EngineStatus) GetConditions 

func (x *EngineStatus) GetConditions() *EngineConditions

func (*EngineStatus) GetDetails 

func (x *EngineStatus) GetDetails() string

func (*EngineStatus) GetMetadata 

func (x *EngineStatus) GetMetadata() *EngineMetadata

func (*EngineStatus) GetName 

func (x *EngineStatus) GetName() string

func (*EngineStatus) GetPhase 

func (x *EngineStatus) GetPhase() EnginePhase

func (*EngineStatus) GetResults 

func (x *EngineStatus) GetResults() []*EngineResult

func (*EngineStatus) ProtoMessage 

func (*EngineStatus) ProtoMessage()

func (*EngineStatus) ProtoReflect 

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

func (*EngineStatus) Reset 

func (x *EngineStatus) Reset()

func (*EngineStatus) String 

func (x *EngineStatus) String() string

type EngineTrigger 

type EngineTrigger int32
const (
	EngineTrigger_TRIGGER_UNKNOWN EngineTrigger = 0
	EngineTrigger_TRIGGER_MANUAL  EngineTrigger = 1
	EngineTrigger_TRIGGER_PUSH    EngineTrigger = 2
	EngineTrigger_TRIGGER_DELETED EngineTrigger = 3
)

func (EngineTrigger) Descriptor 

func (EngineTrigger) Descriptor() protoreflect.EnumDescriptor

func (EngineTrigger) Enum 

func (x EngineTrigger) Enum() *EngineTrigger

func (EngineTrigger) EnumDescriptor deprecated 

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

Deprecated: Use EngineTrigger.Descriptor instead.

func (EngineTrigger) Number 

func (x EngineTrigger) Number() protoreflect.EnumNumber

func (EngineTrigger) String 

func (x EngineTrigger) String() string

func (EngineTrigger) Type 

func (EngineTrigger) Type() protoreflect.EnumType

type FilterExpression 

type FilterExpression struct {
	Terms []*FilterTerm `protobuf:"bytes,1,rep,name=terms,proto3" json:"terms,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterExpression) Descriptor deprecated 

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

Deprecated: Use FilterExpression.ProtoReflect.Descriptor instead.

func (*FilterExpression) GetTerms 

func (x *FilterExpression) GetTerms() []*FilterTerm

func (*FilterExpression) ProtoMessage 

func (*FilterExpression) ProtoMessage()

func (*FilterExpression) ProtoReflect 

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

func (*FilterExpression) Reset 

func (x *FilterExpression) Reset()

func (*FilterExpression) String 

func (x *FilterExpression) String() string

type FilterOp 

type FilterOp int32
const (
	FilterOp_OP_EQUALS      FilterOp = 0
	FilterOp_OP_STARTS_WITH FilterOp = 1
	FilterOp_OP_ENDS_WITH   FilterOp = 2
	FilterOp_OP_CONTAINS    FilterOp = 3
	FilterOp_OP_EXISTS      FilterOp = 4
)

func (FilterOp) Descriptor 

func (FilterOp) Descriptor() protoreflect.EnumDescriptor

func (FilterOp) Enum 

func (x FilterOp) Enum() *FilterOp

func (FilterOp) EnumDescriptor deprecated 

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

Deprecated: Use FilterOp.Descriptor instead.

func (FilterOp) Number 

func (x FilterOp) Number() protoreflect.EnumNumber

func (FilterOp) String 

func (x FilterOp) String() string

func (FilterOp) Type 

func (FilterOp) Type() protoreflect.EnumType

type FilterTerm 

type FilterTerm struct {
	Field     string   `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Value     string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Operation FilterOp `protobuf:"varint,3,opt,name=operation,proto3,enum=v1.FilterOp" json:"operation,omitempty"`
	Negate    bool     `protobuf:"varint,4,opt,name=negate,proto3" json:"negate,omitempty"`
	// contains filtered or unexported fields
}

func (*FilterTerm) Descriptor deprecated 

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

Deprecated: Use FilterTerm.ProtoReflect.Descriptor instead.

func (*FilterTerm) GetField 

func (x *FilterTerm) GetField() string

func (*FilterTerm) GetNegate 

func (x *FilterTerm) GetNegate() bool

func (*FilterTerm) GetOperation 

func (x *FilterTerm) GetOperation() FilterOp

func (*FilterTerm) GetValue 

func (x *FilterTerm) GetValue() string

func (*FilterTerm) ProtoMessage 

func (*FilterTerm) ProtoMessage()

func (*FilterTerm) ProtoReflect 

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

func (*FilterTerm) Reset 

func (x *FilterTerm) Reset()

func (*FilterTerm) String 

func (x *FilterTerm) String() string

type GetEngineRequest 

type GetEngineRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEngineRequest) Descriptor deprecated 

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

Deprecated: Use GetEngineRequest.ProtoReflect.Descriptor instead.

func (*GetEngineRequest) GetName 

func (x *GetEngineRequest) GetName() string

func (*GetEngineRequest) ProtoMessage 

func (*GetEngineRequest) ProtoMessage()

func (*GetEngineRequest) ProtoReflect 

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

func (*GetEngineRequest) Reset 

func (x *GetEngineRequest) Reset()

func (*GetEngineRequest) String 

func (x *GetEngineRequest) String() string

type GetEngineResponse 

type GetEngineResponse struct {
	Result *EngineStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetEngineResponse) Descriptor deprecated 

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

Deprecated: Use GetEngineResponse.ProtoReflect.Descriptor instead.

func (*GetEngineResponse) GetResult 

func (x *GetEngineResponse) GetResult() *EngineStatus

func (*GetEngineResponse) ProtoMessage 

func (*GetEngineResponse) ProtoMessage()

func (*GetEngineResponse) ProtoReflect 

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

func (*GetEngineResponse) Reset 

func (x *GetEngineResponse) Reset()

func (*GetEngineResponse) String 

func (x *GetEngineResponse) String() string

type IsReadOnlyRequest 

type IsReadOnlyRequest struct {
	// contains filtered or unexported fields
}

func (*IsReadOnlyRequest) Descriptor deprecated 

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

Deprecated: Use IsReadOnlyRequest.ProtoReflect.Descriptor instead.

func (*IsReadOnlyRequest) ProtoMessage 

func (*IsReadOnlyRequest) ProtoMessage()

func (*IsReadOnlyRequest) ProtoReflect 

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

func (*IsReadOnlyRequest) Reset 

func (x *IsReadOnlyRequest) Reset()

func (*IsReadOnlyRequest) String 

func (x *IsReadOnlyRequest) String() string

type IsReadOnlyResponse 

type IsReadOnlyResponse struct {
	Readonly bool `protobuf:"varint,1,opt,name=readonly,proto3" json:"readonly,omitempty"`
	// contains filtered or unexported fields
}

func (*IsReadOnlyResponse) Descriptor deprecated 

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

Deprecated: Use IsReadOnlyResponse.ProtoReflect.Descriptor instead.

func (*IsReadOnlyResponse) GetReadonly 

func (x *IsReadOnlyResponse) GetReadonly() bool

func (*IsReadOnlyResponse) ProtoMessage 

func (*IsReadOnlyResponse) ProtoMessage()

func (*IsReadOnlyResponse) ProtoReflect 

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

func (*IsReadOnlyResponse) Reset 

func (x *IsReadOnlyResponse) Reset()

func (*IsReadOnlyResponse) String 

func (x *IsReadOnlyResponse) String() string

type ListEngineSpecsRequest 

type ListEngineSpecsRequest struct {
	// contains filtered or unexported fields
}

func (*ListEngineSpecsRequest) Descriptor deprecated 

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

Deprecated: Use ListEngineSpecsRequest.ProtoReflect.Descriptor instead.

func (*ListEngineSpecsRequest) ProtoMessage 

func (*ListEngineSpecsRequest) ProtoMessage()

func (*ListEngineSpecsRequest) ProtoReflect 

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

func (*ListEngineSpecsRequest) Reset 

func (x *ListEngineSpecsRequest) Reset()

func (*ListEngineSpecsRequest) String 

func (x *ListEngineSpecsRequest) String() string

type ListEngineSpecsResponse 

type ListEngineSpecsResponse struct {
	Repo        *Repository          `protobuf:"bytes,1,opt,name=repo,proto3" json:"repo,omitempty"`
	Name        string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Path        string               `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Description string               `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	Arguments   []*DesiredAnnotation `protobuf:"bytes,5,rep,name=arguments,proto3" json:"arguments,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEngineSpecsResponse) Descriptor deprecated 

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

Deprecated: Use ListEngineSpecsResponse.ProtoReflect.Descriptor instead.

func (*ListEngineSpecsResponse) GetArguments 

func (x *ListEngineSpecsResponse) GetArguments() []*DesiredAnnotation

func (*ListEngineSpecsResponse) GetDescription 

func (x *ListEngineSpecsResponse) GetDescription() string

func (*ListEngineSpecsResponse) GetName 

func (x *ListEngineSpecsResponse) GetName() string

func (*ListEngineSpecsResponse) GetPath 

func (x *ListEngineSpecsResponse) GetPath() string

func (*ListEngineSpecsResponse) GetRepo 

func (x *ListEngineSpecsResponse) GetRepo() *Repository

func (*ListEngineSpecsResponse) ProtoMessage 

func (*ListEngineSpecsResponse) ProtoMessage()

func (*ListEngineSpecsResponse) ProtoReflect 

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

func (*ListEngineSpecsResponse) Reset 

func (x *ListEngineSpecsResponse) Reset()

func (*ListEngineSpecsResponse) String 

func (x *ListEngineSpecsResponse) String() string

type ListEnginesRequest 

type ListEnginesRequest struct {
	Filter []*FilterExpression `protobuf:"bytes,1,rep,name=filter,proto3" json:"filter,omitempty"`
	Order  []*OrderExpression  `protobuf:"bytes,2,rep,name=order,proto3" json:"order,omitempty"`
	Start  int32               `protobuf:"varint,3,opt,name=start,proto3" json:"start,omitempty"`
	Limit  int32               `protobuf:"varint,4,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEnginesRequest) Descriptor deprecated 

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

Deprecated: Use ListEnginesRequest.ProtoReflect.Descriptor instead.

func (*ListEnginesRequest) GetFilter 

func (x *ListEnginesRequest) GetFilter() []*FilterExpression

func (*ListEnginesRequest) GetLimit 

func (x *ListEnginesRequest) GetLimit() int32

func (*ListEnginesRequest) GetOrder 

func (x *ListEnginesRequest) GetOrder() []*OrderExpression

func (*ListEnginesRequest) GetStart 

func (x *ListEnginesRequest) GetStart() int32

func (*ListEnginesRequest) ProtoMessage 

func (*ListEnginesRequest) ProtoMessage()

func (*ListEnginesRequest) ProtoReflect 

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

func (*ListEnginesRequest) Reset 

func (x *ListEnginesRequest) Reset()

func (*ListEnginesRequest) String 

func (x *ListEnginesRequest) String() string

type ListEnginesResponse 

type ListEnginesResponse struct {
	Total  int32           `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Result []*EngineStatus `protobuf:"bytes,2,rep,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ListEnginesResponse) Descriptor deprecated 

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

Deprecated: Use ListEnginesResponse.ProtoReflect.Descriptor instead.

func (*ListEnginesResponse) GetResult 

func (x *ListEnginesResponse) GetResult() []*EngineStatus

func (*ListEnginesResponse) GetTotal 

func (x *ListEnginesResponse) GetTotal() int32

func (*ListEnginesResponse) ProtoMessage 

func (*ListEnginesResponse) ProtoMessage()

func (*ListEnginesResponse) ProtoReflect 

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

func (*ListEnginesResponse) Reset 

func (x *ListEnginesResponse) Reset()

func (*ListEnginesResponse) String 

func (x *ListEnginesResponse) String() string

type ListenRequest 

type ListenRequest struct {
	Name    string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Updates bool              `protobuf:"varint,2,opt,name=updates,proto3" json:"updates,omitempty"`
	Logs    ListenRequestLogs `protobuf:"varint,3,opt,name=logs,proto3,enum=v1.ListenRequestLogs" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListenRequest) Descriptor deprecated 

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

Deprecated: Use ListenRequest.ProtoReflect.Descriptor instead.

func (*ListenRequest) GetLogs 

func (x *ListenRequest) GetLogs() ListenRequestLogs

func (*ListenRequest) GetName 

func (x *ListenRequest) GetName() string

func (*ListenRequest) GetUpdates 

func (x *ListenRequest) GetUpdates() bool

func (*ListenRequest) ProtoMessage 

func (*ListenRequest) ProtoMessage()

func (*ListenRequest) ProtoReflect 

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

func (*ListenRequest) Reset 

func (x *ListenRequest) Reset()

func (*ListenRequest) String 

func (x *ListenRequest) String() string

type ListenRequestLogs 

type ListenRequestLogs int32
const (
	ListenRequestLogs_LOGS_DISABLED ListenRequestLogs = 0
	ListenRequestLogs_LOGS_UNSLICED ListenRequestLogs = 1
	ListenRequestLogs_LOGS_RAW      ListenRequestLogs = 2
	ListenRequestLogs_LOGS_HTML     ListenRequestLogs = 3
)

func (ListenRequestLogs) Descriptor 

func (ListenRequestLogs) Descriptor() protoreflect.EnumDescriptor

func (ListenRequestLogs) Enum 

func (x ListenRequestLogs) Enum() *ListenRequestLogs

func (ListenRequestLogs) EnumDescriptor deprecated 

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

Deprecated: Use ListenRequestLogs.Descriptor instead.

func (ListenRequestLogs) Number 

func (x ListenRequestLogs) Number() protoreflect.EnumNumber

func (ListenRequestLogs) String 

func (x ListenRequestLogs) String() string

func (ListenRequestLogs) Type 

func (ListenRequestLogs) Type() protoreflect.EnumType

type ListenResponse 

type ListenResponse struct {

	// Types that are assignable to Content:
	//	*ListenResponse_Update
	//	*ListenResponse_Slice
	Content isListenResponse_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*ListenResponse) Descriptor deprecated 

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

Deprecated: Use ListenResponse.ProtoReflect.Descriptor instead.

func (*ListenResponse) GetContent 

func (m *ListenResponse) GetContent() isListenResponse_Content

func (*ListenResponse) GetSlice 

func (x *ListenResponse) GetSlice() *LogSliceEvent

func (*ListenResponse) GetUpdate 

func (x *ListenResponse) GetUpdate() *EngineStatus

func (*ListenResponse) ProtoMessage 

func (*ListenResponse) ProtoMessage()

func (*ListenResponse) ProtoReflect 

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

func (*ListenResponse) Reset 

func (x *ListenResponse) Reset()

func (*ListenResponse) String 

func (x *ListenResponse) String() string

type ListenResponse_Slice 

type ListenResponse_Slice struct {
	Slice *LogSliceEvent `protobuf:"bytes,2,opt,name=slice,proto3,oneof"`
}

type ListenResponse_Update 

type ListenResponse_Update struct {
	Update *EngineStatus `protobuf:"bytes,1,opt,name=update,proto3,oneof"`
}

type LogSliceEvent 

type LogSliceEvent struct {
	Name    string       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type    LogSliceType `protobuf:"varint,2,opt,name=type,proto3,enum=v1.LogSliceType" json:"type,omitempty"`
	Payload string       `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSliceEvent) Descriptor deprecated 

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

Deprecated: Use LogSliceEvent.ProtoReflect.Descriptor instead.

func (*LogSliceEvent) GetName 

func (x *LogSliceEvent) GetName() string

func (*LogSliceEvent) GetPayload 

func (x *LogSliceEvent) GetPayload() string

func (*LogSliceEvent) GetType 

func (x *LogSliceEvent) GetType() LogSliceType

func (*LogSliceEvent) ProtoMessage 

func (*LogSliceEvent) ProtoMessage()

func (*LogSliceEvent) ProtoReflect 

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

func (*LogSliceEvent) Reset 

func (x *LogSliceEvent) Reset()

func (*LogSliceEvent) String 

func (x *LogSliceEvent) String() string

type LogSliceType 

type LogSliceType int32
const (
	LogSliceType_SLICE_ABANDONED LogSliceType = 0
	LogSliceType_SLICE_PHASE     LogSliceType = 1
	LogSliceType_SLICE_START     LogSliceType = 2
	LogSliceType_SLICE_CONTENT   LogSliceType = 3
	LogSliceType_SLICE_DONE      LogSliceType = 4
	LogSliceType_SLICE_FAIL      LogSliceType = 5
	LogSliceType_SLICE_RESULT    LogSliceType = 6
)

func (LogSliceType) Descriptor 

func (LogSliceType) Descriptor() protoreflect.EnumDescriptor

func (LogSliceType) Enum 

func (x LogSliceType) Enum() *LogSliceType

func (LogSliceType) EnumDescriptor deprecated 

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

Deprecated: Use LogSliceType.Descriptor instead.

func (LogSliceType) Number 

func (x LogSliceType) Number() protoreflect.EnumNumber

func (LogSliceType) String 

func (x LogSliceType) String() string

func (LogSliceType) Type 

func (LogSliceType) Type() protoreflect.EnumType

type OrderExpression 

type OrderExpression struct {
	Field     string `protobuf:"bytes,1,opt,name=field,proto3" json:"field,omitempty"`
	Ascending bool   `protobuf:"varint,2,opt,name=ascending,proto3" json:"ascending,omitempty"`
	// contains filtered or unexported fields
}

func (*OrderExpression) Descriptor deprecated 

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

Deprecated: Use OrderExpression.ProtoReflect.Descriptor instead.

func (*OrderExpression) GetAscending 

func (x *OrderExpression) GetAscending() bool

func (*OrderExpression) GetField 

func (x *OrderExpression) GetField() string

func (*OrderExpression) ProtoMessage 

func (*OrderExpression) ProtoMessage()

func (*OrderExpression) ProtoReflect 

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

func (*OrderExpression) Reset 

func (x *OrderExpression) Reset()

func (*OrderExpression) String 

func (x *OrderExpression) String() string

type Repository 

type Repository struct {
	Host     string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Owner    string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	Repo     string `protobuf:"bytes,3,opt,name=repo,proto3" json:"repo,omitempty"`
	Ref      string `protobuf:"bytes,4,opt,name=ref,proto3" json:"ref,omitempty"`
	Revision string `protobuf:"bytes,5,opt,name=revision,proto3" json:"revision,omitempty"`
	// contains filtered or unexported fields
}

func (*Repository) Descriptor deprecated 

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

Deprecated: Use Repository.ProtoReflect.Descriptor instead.

func (*Repository) GetHost 

func (x *Repository) GetHost() string

func (*Repository) GetOwner 

func (x *Repository) GetOwner() string

func (*Repository) GetRef 

func (x *Repository) GetRef() string

func (*Repository) GetRepo 

func (x *Repository) GetRepo() string

func (*Repository) GetRevision 

func (x *Repository) GetRevision() string

func (*Repository) ProtoMessage 

func (*Repository) ProtoMessage()

func (*Repository) ProtoReflect 

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

func (*Repository) Reset 

func (x *Repository) Reset()

func (*Repository) String 

func (x *Repository) String() string

type StartEngineRequest 

type StartEngineRequest struct {
	Metadata   *EngineMetadata        `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	EnginePath string                 `protobuf:"bytes,2,opt,name=engine_path,json=enginePath,proto3" json:"engine_path,omitempty"`
	EngineYaml []byte                 `protobuf:"bytes,3,opt,name=engine_yaml,json=engineYaml,proto3" json:"engine_yaml,omitempty"`
	Sideload   []byte                 `protobuf:"bytes,4,opt,name=sideload,proto3" json:"sideload,omitempty"`
	WaitUntil  *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	NameSuffix string                 `protobuf:"bytes,6,opt,name=name_suffix,json=nameSuffix,proto3" json:"name_suffix,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEngineRequest) Descriptor deprecated 

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

Deprecated: Use StartEngineRequest.ProtoReflect.Descriptor instead.

func (*StartEngineRequest) GetEnginePath 

func (x *StartEngineRequest) GetEnginePath() string

func (*StartEngineRequest) GetEngineYaml 

func (x *StartEngineRequest) GetEngineYaml() []byte

func (*StartEngineRequest) GetMetadata 

func (x *StartEngineRequest) GetMetadata() *EngineMetadata

func (*StartEngineRequest) GetNameSuffix 

func (x *StartEngineRequest) GetNameSuffix() string

func (*StartEngineRequest) GetSideload 

func (x *StartEngineRequest) GetSideload() []byte

func (*StartEngineRequest) GetWaitUntil 

func (x *StartEngineRequest) GetWaitUntil() *timestamppb.Timestamp

func (*StartEngineRequest) ProtoMessage 

func (*StartEngineRequest) ProtoMessage()

func (*StartEngineRequest) ProtoReflect 

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

func (*StartEngineRequest) Reset 

func (x *StartEngineRequest) Reset()

func (*StartEngineRequest) String 

func (x *StartEngineRequest) String() string

type StartEngineResponse 

type StartEngineResponse struct {
	Status *EngineStatus `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEngineResponse) Descriptor deprecated 

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

Deprecated: Use StartEngineResponse.ProtoReflect.Descriptor instead.

func (*StartEngineResponse) GetStatus 

func (x *StartEngineResponse) GetStatus() *EngineStatus

func (*StartEngineResponse) ProtoMessage 

func (*StartEngineResponse) ProtoMessage()

func (*StartEngineResponse) ProtoReflect 

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

func (*StartEngineResponse) Reset 

func (x *StartEngineResponse) Reset()

func (*StartEngineResponse) String 

func (x *StartEngineResponse) String() string

type StartFromPreviousEngineRequest 

type StartFromPreviousEngineRequest struct {
	PreviousEngine string                 `protobuf:"bytes,1,opt,name=previous_engine,json=previousEngine,proto3" json:"previous_engine,omitempty"`
	GitopsToken    string                 `protobuf:"bytes,2,opt,name=gitops_token,json=gitopsToken,proto3" json:"gitops_token,omitempty"`
	WaitUntil      *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=wait_until,json=waitUntil,proto3" json:"wait_until,omitempty"`
	// contains filtered or unexported fields
}

func (*StartFromPreviousEngineRequest) Descriptor deprecated 

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

Deprecated: Use StartFromPreviousEngineRequest.ProtoReflect.Descriptor instead.

func (*StartFromPreviousEngineRequest) GetGitopsToken 

func (x *StartFromPreviousEngineRequest) GetGitopsToken() string

func (*StartFromPreviousEngineRequest) GetPreviousEngine 

func (x *StartFromPreviousEngineRequest) GetPreviousEngine() string

func (*StartFromPreviousEngineRequest) GetWaitUntil 

func (x *StartFromPreviousEngineRequest) GetWaitUntil() *timestamppb.Timestamp

func (*StartFromPreviousEngineRequest) ProtoMessage 

func (*StartFromPreviousEngineRequest) ProtoMessage()

func (*StartFromPreviousEngineRequest) ProtoReflect 

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

func (*StartFromPreviousEngineRequest) Reset 

func (x *StartFromPreviousEngineRequest) Reset()

func (*StartFromPreviousEngineRequest) String 

func (x *StartFromPreviousEngineRequest) String() string

type StartLocalEngineRequest 

type StartLocalEngineRequest struct {

	// Types that are assignable to Content:
	//	*StartLocalEngineRequest_Metadata
	//	*StartLocalEngineRequest_ConfigYaml
	//	*StartLocalEngineRequest_EngineYaml
	//	*StartLocalEngineRequest_ApplicationTar
	//	*StartLocalEngineRequest_ApplicationTarDone
	Content isStartLocalEngineRequest_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

func (*StartLocalEngineRequest) Descriptor deprecated 

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

Deprecated: Use StartLocalEngineRequest.ProtoReflect.Descriptor instead.

func (*StartLocalEngineRequest) GetApplicationTar 

func (x *StartLocalEngineRequest) GetApplicationTar() []byte

func (*StartLocalEngineRequest) GetApplicationTarDone 

func (x *StartLocalEngineRequest) GetApplicationTarDone() bool

func (*StartLocalEngineRequest) GetConfigYaml 

func (x *StartLocalEngineRequest) GetConfigYaml() []byte

func (*StartLocalEngineRequest) GetContent 

func (m *StartLocalEngineRequest) GetContent() isStartLocalEngineRequest_Content

func (*StartLocalEngineRequest) GetEngineYaml 

func (x *StartLocalEngineRequest) GetEngineYaml() []byte

func (*StartLocalEngineRequest) GetMetadata 

func (x *StartLocalEngineRequest) GetMetadata() *EngineMetadata

func (*StartLocalEngineRequest) ProtoMessage 

func (*StartLocalEngineRequest) ProtoMessage()

func (*StartLocalEngineRequest) ProtoReflect 

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

func (*StartLocalEngineRequest) Reset 

func (x *StartLocalEngineRequest) Reset()

func (*StartLocalEngineRequest) String 

func (x *StartLocalEngineRequest) String() string

type StartLocalEngineRequest_ApplicationTar 

type StartLocalEngineRequest_ApplicationTar struct {
	ApplicationTar []byte `protobuf:"bytes,4,opt,name=application_tar,json=applicationTar,proto3,oneof"`
}

type StartLocalEngineRequest_ApplicationTarDone 

type StartLocalEngineRequest_ApplicationTarDone struct {
	ApplicationTarDone bool `protobuf:"varint,5,opt,name=application_tar_done,json=applicationTarDone,proto3,oneof"`
}

type StartLocalEngineRequest_ConfigYaml 

type StartLocalEngineRequest_ConfigYaml struct {
	ConfigYaml []byte `protobuf:"bytes,2,opt,name=config_yaml,json=configYaml,proto3,oneof"`
}

type StartLocalEngineRequest_EngineYaml 

type StartLocalEngineRequest_EngineYaml struct {
	EngineYaml []byte `protobuf:"bytes,3,opt,name=engine_yaml,json=engineYaml,proto3,oneof"`
}

type StartLocalEngineRequest_Metadata 

type StartLocalEngineRequest_Metadata struct {
	Metadata *EngineMetadata `protobuf:"bytes,1,opt,name=metadata,proto3,oneof"`
}

type StopEngineRequest 

type StopEngineRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*StopEngineRequest) Descriptor deprecated 

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

Deprecated: Use StopEngineRequest.ProtoReflect.Descriptor instead.

func (*StopEngineRequest) GetName 

func (x *StopEngineRequest) GetName() string

func (*StopEngineRequest) ProtoMessage 

func (*StopEngineRequest) ProtoMessage()

func (*StopEngineRequest) ProtoReflect 

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

func (*StopEngineRequest) Reset 

func (x *StopEngineRequest) Reset()

func (*StopEngineRequest) String 

func (x *StopEngineRequest) String() string

type StopEngineResponse 

type StopEngineResponse struct {
	// contains filtered or unexported fields
}

func (*StopEngineResponse) Descriptor deprecated 

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

Deprecated: Use StopEngineResponse.ProtoReflect.Descriptor instead.

func (*StopEngineResponse) ProtoMessage 

func (*StopEngineResponse) ProtoMessage()

func (*StopEngineResponse) ProtoReflect 

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

func (*StopEngineResponse) Reset 

func (x *StopEngineResponse) Reset()

func (*StopEngineResponse) String 

func (x *StopEngineResponse) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Filter []*FilterExpression `protobuf:"bytes,1,rep,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetFilter 

func (x *SubscribeRequest) GetFilter() []*FilterExpression

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {
	Result *EngineStatus `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetResult 

func (x *SubscribeResponse) GetResult() *EngineStatus

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type UnimplementedCacheServiceServer 

type UnimplementedCacheServiceServer struct {
}

UnimplementedCacheServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheServiceServer) GetEngine 

func (UnimplementedCacheServiceServer) GetEngine(context.Context, *GetEngineRequest) (*GetEngineResponse, error)

func (UnimplementedCacheServiceServer) ListEngines 

func (UnimplementedCacheServiceServer) ListEngines(context.Context, *ListEnginesRequest) (*ListEnginesResponse, error)

func (UnimplementedCacheServiceServer) Listen 

func (UnimplementedCacheServiceServer) Listen(*ListenRequest, CacheService_ListenServer) error

func (UnimplementedCacheServiceServer) StartEngine 

func (UnimplementedCacheServiceServer) StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)

func (UnimplementedCacheServiceServer) StartFromPreviousEngine 

func (UnimplementedCacheServiceServer) StartFromPreviousEngine(context.Context, *StartFromPreviousEngineRequest) (*StartEngineResponse, error)

func (UnimplementedCacheServiceServer) StartLocalEngine 

func (UnimplementedCacheServiceServer) StartLocalEngine(CacheService_StartLocalEngineServer) error

func (UnimplementedCacheServiceServer) StopEngine 

func (UnimplementedCacheServiceServer) StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)

func (UnimplementedCacheServiceServer) Subscribe 

func (UnimplementedCacheServiceServer) Subscribe(*SubscribeRequest, CacheService_SubscribeServer) error

type UnimplementedCacheUIServer 

type UnimplementedCacheUIServer struct {
}

UnimplementedCacheUIServer must be embedded to have forward compatible implementations.

func (UnimplementedCacheUIServer) IsReadOnly 

func (UnimplementedCacheUIServer) IsReadOnly(context.Context, *IsReadOnlyRequest) (*IsReadOnlyResponse, error)

func (UnimplementedCacheUIServer) ListEngineSpecs 

func (UnimplementedCacheUIServer) ListEngineSpecs(*ListEngineSpecsRequest, CacheUI_ListEngineSpecsServer) error

type UnsafeCacheServiceServer 

type UnsafeCacheServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeCacheServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheServiceServer will result in compilation errors.

type UnsafeCacheUIServer 

type UnsafeCacheUIServer interface {
	// contains filtered or unexported methods
}

UnsafeCacheUIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CacheUIServer will result in compilation errors.

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.