v1

package
v0.0.0-...-97fda5c Latest Latest
Warning

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

 Go to latest Published: Jan 22, 2022 License: GPL-3.0 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 DigitalProviderUI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.DigitalProviderUI",
	HandlerType: (*DigitalProviderUIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IsReadOnly",
			Handler:    _DigitalProviderUI_IsReadOnly_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ListEngineSpecs",
			Handler:       _DigitalProviderUI_ListEngineSpecs_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "provider-ui.proto",
}

DigitalProviderUI_ServiceDesc is the grpc.ServiceDesc for DigitalProviderUI 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 DigitalProvider_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.DigitalProvider",
	HandlerType: (*DigitalProviderServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartFromPreviousEngine",
			Handler:    _DigitalProvider_StartFromPreviousEngine_Handler,
		},
		{
			MethodName: "StartEngine",
			Handler:    _DigitalProvider_StartEngine_Handler,
		},
		{
			MethodName: "ListEngines",
			Handler:    _DigitalProvider_ListEngines_Handler,
		},
		{
			MethodName: "GetEngine",
			Handler:    _DigitalProvider_GetEngine_Handler,
		},
		{
			MethodName: "StopEngine",
			Handler:    _DigitalProvider_StopEngine_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StartLocalEngine",
			Handler:       _DigitalProvider_StartLocalEngine_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DigitalProvider_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Listen",
			Handler:       _DigitalProvider_Listen_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "provider.proto",
}

DigitalProvider_ServiceDesc is the grpc.ServiceDesc for DigitalProvider 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_provider_proto protoreflect.FileDescriptor
View Source 
var File_provider_ui_proto protoreflect.FileDescriptor

Functions

func RegisterDigitalProviderServer 

func RegisterDigitalProviderServer(s grpc.ServiceRegistrar, srv DigitalProviderServer)

func RegisterDigitalProviderUIServer 

func RegisterDigitalProviderUIServer(s grpc.ServiceRegistrar, srv DigitalProviderUIServer)

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

type DigitalProviderClient interface {
	// StartLocalEngine starts a Provider Engine on the Bhojpur.NET Platform directly.
	// The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the provider/config.yaml
	//   3. all bytes constituting the Provider 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) (DigitalProvider_StartLocalEngineClient, error)
	// StartFromPreviousEngine starts a new Provider Engine based on a previous one.
	// If the previous Provider 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 Provider Engine based on its specification.
	StartEngine(ctx context.Context, in *StartEngineRequest, opts ...grpc.CallOption) (*StartEngineResponse, error)
	// Searches for Provider Engine(s) known to this Provider Engine
	ListEngines(ctx context.Context, in *ListEnginesRequest, opts ...grpc.CallOption) (*ListEnginesResponse, error)
	// Subscribe listens to new Provider Engine(s) updates
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (DigitalProvider_SubscribeClient, error)
	// GetEngine retrieves details of a single Provider Engine
	GetEngine(ctx context.Context, in *GetEngineRequest, opts ...grpc.CallOption) (*GetEngineResponse, error)
	// Listen listens to Provider Engine updates and log output of a running Engine
	Listen(ctx context.Context, in *ListenRequest, opts ...grpc.CallOption) (DigitalProvider_ListenClient, error)
	// StopEngine stops a currently running Provider Engine
	StopEngine(ctx context.Context, in *StopEngineRequest, opts ...grpc.CallOption) (*StopEngineResponse, error)
}

DigitalProviderClient is the client API for DigitalProvider 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 NewDigitalProviderClient 

func NewDigitalProviderClient(cc grpc.ClientConnInterface) DigitalProviderClient

type DigitalProviderServer 

type DigitalProviderServer interface {
	// StartLocalEngine starts a Provider Engine on the Bhojpur.NET Platform directly.
	// The incoming requests are expected in the following order:
	//   1. metadata
	//   2. all bytes constituting the provider/config.yaml
	//   3. all bytes constituting the Provider 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(DigitalProvider_StartLocalEngineServer) error
	// StartFromPreviousEngine starts a new Provider Engine based on a previous one.
	// If the previous Provider 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 Provider Engine based on its specification.
	StartEngine(context.Context, *StartEngineRequest) (*StartEngineResponse, error)
	// Searches for Provider Engine(s) known to this Provider Engine
	ListEngines(context.Context, *ListEnginesRequest) (*ListEnginesResponse, error)
	// Subscribe listens to new Provider Engine(s) updates
	Subscribe(*SubscribeRequest, DigitalProvider_SubscribeServer) error
	// GetEngine retrieves details of a single Provider Engine
	GetEngine(context.Context, *GetEngineRequest) (*GetEngineResponse, error)
	// Listen listens to Provider Engine updates and log output of a running Engine
	Listen(*ListenRequest, DigitalProvider_ListenServer) error
	// StopEngine stops a currently running Provider Engine
	StopEngine(context.Context, *StopEngineRequest) (*StopEngineResponse, error)
	// contains filtered or unexported methods
}

DigitalProviderServer is the server API for DigitalProvider service. All implementations must embed UnimplementedDigitalProviderServer for forward compatibility

type DigitalProviderUIClient 

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

DigitalProviderUIClient is the client API for DigitalProviderUI 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 NewDigitalProviderUIClient 

func NewDigitalProviderUIClient(cc grpc.ClientConnInterface) DigitalProviderUIClient

type DigitalProviderUIServer 

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

DigitalProviderUIServer is the server API for DigitalProviderUI service. All implementations must embed UnimplementedDigitalProviderUIServer for forward compatibility

type DigitalProviderUI_ListEngineSpecsClient 

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

type DigitalProviderUI_ListEngineSpecsServer 

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

type DigitalProvider_ListenClient 

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

type DigitalProvider_ListenServer 

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

type DigitalProvider_StartLocalEngineClient 

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

type DigitalProvider_StartLocalEngineServer 

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

type DigitalProvider_SubscribeClient 

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

type DigitalProvider_SubscribeServer 

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

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 Provider Engine is in
	EnginePhase_PHASE_UNKNOWN EnginePhase = 0
	// Preparing means the Provider Engine hasn't started yet and isn't consuming resources in the system
	EnginePhase_PHASE_PREPARING EnginePhase = 1
	// Starting means the Provider 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 Provider Provider Engine is actually running and doing work.
	EnginePhase_PHASE_RUNNING EnginePhase = 3
	// Done means the Provider Engine has run and is finished
	EnginePhase_PHASE_DONE EnginePhase = 4
	// Cleaning means the Provider Engine is in post-run cleanup
	EnginePhase_PHASE_CLEANUP EnginePhase = 5
	// Waiting means the Provider 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 UnimplementedDigitalProviderServer 

type UnimplementedDigitalProviderServer struct {
}

UnimplementedDigitalProviderServer must be embedded to have forward compatible implementations.

func (UnimplementedDigitalProviderServer) GetEngine 

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

func (UnimplementedDigitalProviderServer) ListEngines 

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

func (UnimplementedDigitalProviderServer) Listen 

func (UnimplementedDigitalProviderServer) Listen(*ListenRequest, DigitalProvider_ListenServer) error

func (UnimplementedDigitalProviderServer) StartEngine 

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

func (UnimplementedDigitalProviderServer) StartFromPreviousEngine 

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

func (UnimplementedDigitalProviderServer) StartLocalEngine 

func (UnimplementedDigitalProviderServer) StartLocalEngine(DigitalProvider_StartLocalEngineServer) error

func (UnimplementedDigitalProviderServer) StopEngine 

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

func (UnimplementedDigitalProviderServer) Subscribe 

func (UnimplementedDigitalProviderServer) Subscribe(*SubscribeRequest, DigitalProvider_SubscribeServer) error

type UnimplementedDigitalProviderUIServer 

type UnimplementedDigitalProviderUIServer struct {
}

UnimplementedDigitalProviderUIServer must be embedded to have forward compatible implementations.

func (UnimplementedDigitalProviderUIServer) IsReadOnly 

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

func (UnimplementedDigitalProviderUIServer) ListEngineSpecs 

func (UnimplementedDigitalProviderUIServer) ListEngineSpecs(*ListEngineSpecsRequest, DigitalProviderUI_ListEngineSpecsServer) error

type UnsafeDigitalProviderServer 

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

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

type UnsafeDigitalProviderUIServer 

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

UnsafeDigitalProviderUIServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DigitalProviderUIServer 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.