ftlv1

package
v0.202.3 Latest Latest
Warning

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

 Go to latest Published: May 7, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DeploymentChangeType_name = map[int32]string{
		0: "DEPLOYMENT_ADDED",
		1: "DEPLOYMENT_REMOVED",
		2: "DEPLOYMENT_CHANGED",
	}
	DeploymentChangeType_value = map[string]int32{
		"DEPLOYMENT_ADDED":   0,
		"DEPLOYMENT_REMOVED": 1,
		"DEPLOYMENT_CHANGED": 2,
	}
)

Enum value maps for DeploymentChangeType.

View Source 
var (
	RunnerState_name = map[int32]string{
		0: "RUNNER_IDLE",
		1: "RUNNER_RESERVED",
		2: "RUNNER_ASSIGNED",
		3: "RUNNER_DEAD",
	}
	RunnerState_value = map[string]int32{
		"RUNNER_IDLE":     0,
		"RUNNER_RESERVED": 1,
		"RUNNER_ASSIGNED": 2,
		"RUNNER_DEAD":     3,
	}
)

Enum value maps for RunnerState.

View Source 
var (
	ModuleContextResponse_DBType_name = map[int32]string{
		0: "POSTGRES",
	}
	ModuleContextResponse_DBType_value = map[string]int32{
		"POSTGRES": 0,
	}
)

Enum value maps for ModuleContextResponse_DBType.

View Source 
var File_xyz_block_ftl_v1_ftl_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AcquireLeaseRequest added in v0.199.0 

type AcquireLeaseRequest struct {
	Module string               `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Key    []string             `protobuf:"bytes,2,rep,name=key,proto3" json:"key,omitempty"`
	Ttl    *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

func (*AcquireLeaseRequest) Descriptor deprecated added in v0.199.0 

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

Deprecated: Use AcquireLeaseRequest.ProtoReflect.Descriptor instead.

func (*AcquireLeaseRequest) GetKey added in v0.199.0 

func (x *AcquireLeaseRequest) GetKey() []string

func (*AcquireLeaseRequest) GetModule added in v0.199.0 

func (x *AcquireLeaseRequest) GetModule() string

func (*AcquireLeaseRequest) GetTtl added in v0.199.0 

func (x *AcquireLeaseRequest) GetTtl() *durationpb.Duration

func (*AcquireLeaseRequest) ProtoMessage added in v0.199.0 

func (*AcquireLeaseRequest) ProtoMessage()

func (*AcquireLeaseRequest) ProtoReflect added in v0.199.0 

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

func (*AcquireLeaseRequest) Reset added in v0.199.0 

func (x *AcquireLeaseRequest) Reset()

func (*AcquireLeaseRequest) String added in v0.199.0 

func (x *AcquireLeaseRequest) String() string

type AcquireLeaseResponse added in v0.199.0 

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

func (*AcquireLeaseResponse) Descriptor deprecated added in v0.199.0 

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

Deprecated: Use AcquireLeaseResponse.ProtoReflect.Descriptor instead.

func (*AcquireLeaseResponse) ProtoMessage added in v0.199.0 

func (*AcquireLeaseResponse) ProtoMessage()

func (*AcquireLeaseResponse) ProtoReflect added in v0.199.0 

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

func (*AcquireLeaseResponse) Reset added in v0.199.0 

func (x *AcquireLeaseResponse) Reset()

func (*AcquireLeaseResponse) String added in v0.199.0 

func (x *AcquireLeaseResponse) String() string

type CallRequest 

type CallRequest struct {
	Metadata *Metadata   `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
	Verb     *schema.Ref `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	Body     []byte      `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallRequest) Descriptor deprecated 

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

Deprecated: Use CallRequest.ProtoReflect.Descriptor instead.

func (*CallRequest) GetBody 

func (x *CallRequest) GetBody() []byte

func (*CallRequest) GetMetadata 

func (x *CallRequest) GetMetadata() *Metadata

func (*CallRequest) GetVerb 

func (x *CallRequest) GetVerb() *schema.Ref

func (*CallRequest) ProtoMessage 

func (*CallRequest) ProtoMessage()

func (*CallRequest) ProtoReflect 

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

func (*CallRequest) Reset 

func (x *CallRequest) Reset()

func (*CallRequest) String 

func (x *CallRequest) String() string

type CallResponse 

type CallResponse struct {

	// Types that are assignable to Response:
	//
	//	*CallResponse_Body
	//	*CallResponse_Error_
	Response isCallResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor deprecated 

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetBody 

func (x *CallResponse) GetBody() []byte

func (*CallResponse) GetError 

func (x *CallResponse) GetError() *CallResponse_Error

func (*CallResponse) GetResponse 

func (m *CallResponse) GetResponse() isCallResponse_Response

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect 

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

func (*CallResponse) Reset 

func (x *CallResponse) Reset()

func (*CallResponse) String 

func (x *CallResponse) String() string

type CallResponse_Body 

type CallResponse_Body struct {
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3,oneof"`
}

type CallResponse_Error 

type CallResponse_Error struct {
	Message string  `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Stack   *string `protobuf:"bytes,2,opt,name=stack,proto3,oneof" json:"stack,omitempty"` // TODO: Richer error type.
	// contains filtered or unexported fields
}

func (*CallResponse_Error) Descriptor deprecated 

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

Deprecated: Use CallResponse_Error.ProtoReflect.Descriptor instead.

func (*CallResponse_Error) GetMessage 

func (x *CallResponse_Error) GetMessage() string

func (*CallResponse_Error) GetStack 

func (x *CallResponse_Error) GetStack() string

func (*CallResponse_Error) ProtoMessage 

func (*CallResponse_Error) ProtoMessage()

func (*CallResponse_Error) ProtoReflect 

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

func (*CallResponse_Error) Reset 

func (x *CallResponse_Error) Reset()

func (*CallResponse_Error) String 

func (x *CallResponse_Error) String() string

type CallResponse_Error_ 

type CallResponse_Error_ struct {
	Error *CallResponse_Error `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type CreateDeploymentRequest 

type CreateDeploymentRequest struct {
	Schema    *schema.Module        `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Artefacts []*DeploymentArtefact `protobuf:"bytes,2,rep,name=artefacts,proto3" json:"artefacts,omitempty"`
	// Runner labels required to run this deployment.
	Labels *structpb.Struct `protobuf:"bytes,3,opt,name=labels,proto3,oneof" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateDeploymentRequest) Descriptor deprecated 

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

Deprecated: Use CreateDeploymentRequest.ProtoReflect.Descriptor instead.

func (*CreateDeploymentRequest) GetArtefacts 

func (x *CreateDeploymentRequest) GetArtefacts() []*DeploymentArtefact

func (*CreateDeploymentRequest) GetLabels 

func (x *CreateDeploymentRequest) GetLabels() *structpb.Struct

func (*CreateDeploymentRequest) GetSchema 

func (x *CreateDeploymentRequest) GetSchema() *schema.Module

func (*CreateDeploymentRequest) ProtoMessage 

func (*CreateDeploymentRequest) ProtoMessage()

func (*CreateDeploymentRequest) ProtoReflect 

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

func (*CreateDeploymentRequest) Reset 

func (x *CreateDeploymentRequest) Reset()

func (*CreateDeploymentRequest) String 

func (x *CreateDeploymentRequest) String() string

type CreateDeploymentResponse 

type CreateDeploymentResponse struct {
	DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	// Currently active deployment for this module, if any.
	ActiveDeploymentKey *string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateDeploymentResponse) Descriptor deprecated 

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

Deprecated: Use CreateDeploymentResponse.ProtoReflect.Descriptor instead.

func (*CreateDeploymentResponse) GetActiveDeploymentKey added in v0.151.0 

func (x *CreateDeploymentResponse) GetActiveDeploymentKey() string

func (*CreateDeploymentResponse) GetDeploymentKey added in v0.151.0 

func (x *CreateDeploymentResponse) GetDeploymentKey() string

func (*CreateDeploymentResponse) ProtoMessage 

func (*CreateDeploymentResponse) ProtoMessage()

func (*CreateDeploymentResponse) ProtoReflect 

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

func (*CreateDeploymentResponse) Reset 

func (x *CreateDeploymentResponse) Reset()

func (*CreateDeploymentResponse) String 

func (x *CreateDeploymentResponse) String() string

type DeployRequest 

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

func (*DeployRequest) Descriptor deprecated 

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

Deprecated: Use DeployRequest.ProtoReflect.Descriptor instead.

func (*DeployRequest) GetDeploymentKey added in v0.151.0 

func (x *DeployRequest) GetDeploymentKey() string

func (*DeployRequest) ProtoMessage 

func (*DeployRequest) ProtoMessage()

func (*DeployRequest) ProtoReflect 

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

func (*DeployRequest) Reset 

func (x *DeployRequest) Reset()

func (*DeployRequest) String 

func (x *DeployRequest) String() string

type DeployResponse 

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

func (*DeployResponse) Descriptor deprecated 

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

Deprecated: Use DeployResponse.ProtoReflect.Descriptor instead.

func (*DeployResponse) ProtoMessage 

func (*DeployResponse) ProtoMessage()

func (*DeployResponse) ProtoReflect 

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

func (*DeployResponse) Reset 

func (x *DeployResponse) Reset()

func (*DeployResponse) String 

func (x *DeployResponse) String() string

type DeploymentArtefact 

type DeploymentArtefact struct {
	Digest     string `protobuf:"bytes,1,opt,name=digest,proto3" json:"digest,omitempty"`
	Path       string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Executable bool   `protobuf:"varint,3,opt,name=executable,proto3" json:"executable,omitempty"`
	// contains filtered or unexported fields
}

func ArtefactToProto 

func ArtefactToProto(artefact *model.Artefact) *DeploymentArtefact

func (*DeploymentArtefact) Descriptor deprecated 

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

Deprecated: Use DeploymentArtefact.ProtoReflect.Descriptor instead.

func (*DeploymentArtefact) GetDigest 

func (x *DeploymentArtefact) GetDigest() string

func (*DeploymentArtefact) GetExecutable 

func (x *DeploymentArtefact) GetExecutable() bool

func (*DeploymentArtefact) GetPath 

func (x *DeploymentArtefact) GetPath() string

func (*DeploymentArtefact) ProtoMessage 

func (*DeploymentArtefact) ProtoMessage()

func (*DeploymentArtefact) ProtoReflect 

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

func (*DeploymentArtefact) Reset 

func (x *DeploymentArtefact) Reset()

func (*DeploymentArtefact) String 

func (x *DeploymentArtefact) String() string

type DeploymentChangeType 

type DeploymentChangeType int32
const (
	DeploymentChangeType_DEPLOYMENT_ADDED   DeploymentChangeType = 0
	DeploymentChangeType_DEPLOYMENT_REMOVED DeploymentChangeType = 1
	DeploymentChangeType_DEPLOYMENT_CHANGED DeploymentChangeType = 2
)

func (DeploymentChangeType) Descriptor 

func (DeploymentChangeType) Descriptor() protoreflect.EnumDescriptor

func (DeploymentChangeType) Enum 

func (x DeploymentChangeType) Enum() *DeploymentChangeType

func (DeploymentChangeType) EnumDescriptor deprecated 

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

Deprecated: Use DeploymentChangeType.Descriptor instead.

func (DeploymentChangeType) Number 

func (x DeploymentChangeType) Number() protoreflect.EnumNumber

func (DeploymentChangeType) String 

func (x DeploymentChangeType) String() string

func (DeploymentChangeType) Type 

func (DeploymentChangeType) Type() protoreflect.EnumType

type GetArtefactDiffsRequest 

type GetArtefactDiffsRequest struct {
	ClientDigests []string `protobuf:"bytes,1,rep,name=client_digests,json=clientDigests,proto3" json:"client_digests,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtefactDiffsRequest) Descriptor deprecated 

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

Deprecated: Use GetArtefactDiffsRequest.ProtoReflect.Descriptor instead.

func (*GetArtefactDiffsRequest) GetClientDigests 

func (x *GetArtefactDiffsRequest) GetClientDigests() []string

func (*GetArtefactDiffsRequest) ProtoMessage 

func (*GetArtefactDiffsRequest) ProtoMessage()

func (*GetArtefactDiffsRequest) ProtoReflect 

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

func (*GetArtefactDiffsRequest) Reset 

func (x *GetArtefactDiffsRequest) Reset()

func (*GetArtefactDiffsRequest) String 

func (x *GetArtefactDiffsRequest) String() string

type GetArtefactDiffsResponse 

type GetArtefactDiffsResponse struct {
	MissingDigests []string `protobuf:"bytes,1,rep,name=missing_digests,json=missingDigests,proto3" json:"missing_digests,omitempty"`
	// Artefacts that the client already has, and their path+executable status.
	ClientArtefacts []*DeploymentArtefact `protobuf:"bytes,2,rep,name=client_artefacts,json=clientArtefacts,proto3" json:"client_artefacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetArtefactDiffsResponse) Descriptor deprecated 

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

Deprecated: Use GetArtefactDiffsResponse.ProtoReflect.Descriptor instead.

func (*GetArtefactDiffsResponse) GetClientArtefacts 

func (x *GetArtefactDiffsResponse) GetClientArtefacts() []*DeploymentArtefact

func (*GetArtefactDiffsResponse) GetMissingDigests 

func (x *GetArtefactDiffsResponse) GetMissingDigests() []string

func (*GetArtefactDiffsResponse) ProtoMessage 

func (*GetArtefactDiffsResponse) ProtoMessage()

func (*GetArtefactDiffsResponse) ProtoReflect 

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

func (*GetArtefactDiffsResponse) Reset 

func (x *GetArtefactDiffsResponse) Reset()

func (*GetArtefactDiffsResponse) String 

func (x *GetArtefactDiffsResponse) String() string

type GetDeploymentArtefactsRequest 

type GetDeploymentArtefactsRequest struct {
	DeploymentKey string                `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	HaveArtefacts []*DeploymentArtefact `protobuf:"bytes,2,rep,name=have_artefacts,json=haveArtefacts,proto3" json:"have_artefacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeploymentArtefactsRequest) Descriptor deprecated 

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

Deprecated: Use GetDeploymentArtefactsRequest.ProtoReflect.Descriptor instead.

func (*GetDeploymentArtefactsRequest) GetDeploymentKey added in v0.151.0 

func (x *GetDeploymentArtefactsRequest) GetDeploymentKey() string

func (*GetDeploymentArtefactsRequest) GetHaveArtefacts 

func (x *GetDeploymentArtefactsRequest) GetHaveArtefacts() []*DeploymentArtefact

func (*GetDeploymentArtefactsRequest) ProtoMessage 

func (*GetDeploymentArtefactsRequest) ProtoMessage()

func (*GetDeploymentArtefactsRequest) ProtoReflect 

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

func (*GetDeploymentArtefactsRequest) Reset 

func (x *GetDeploymentArtefactsRequest) Reset()

func (*GetDeploymentArtefactsRequest) String 

func (x *GetDeploymentArtefactsRequest) String() string

type GetDeploymentArtefactsResponse 

type GetDeploymentArtefactsResponse struct {
	Artefact *DeploymentArtefact `protobuf:"bytes,1,opt,name=artefact,proto3" json:"artefact,omitempty"`
	Chunk    []byte              `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeploymentArtefactsResponse) Descriptor deprecated 

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

Deprecated: Use GetDeploymentArtefactsResponse.ProtoReflect.Descriptor instead.

func (*GetDeploymentArtefactsResponse) GetArtefact 

func (x *GetDeploymentArtefactsResponse) GetArtefact() *DeploymentArtefact

func (*GetDeploymentArtefactsResponse) GetChunk 

func (x *GetDeploymentArtefactsResponse) GetChunk() []byte

func (*GetDeploymentArtefactsResponse) ProtoMessage 

func (*GetDeploymentArtefactsResponse) ProtoMessage()

func (*GetDeploymentArtefactsResponse) ProtoReflect 

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

func (*GetDeploymentArtefactsResponse) Reset 

func (x *GetDeploymentArtefactsResponse) Reset()

func (*GetDeploymentArtefactsResponse) String 

func (x *GetDeploymentArtefactsResponse) String() string

type GetDeploymentRequest 

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

func (*GetDeploymentRequest) Descriptor deprecated 

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

Deprecated: Use GetDeploymentRequest.ProtoReflect.Descriptor instead.

func (*GetDeploymentRequest) GetDeploymentKey added in v0.151.0 

func (x *GetDeploymentRequest) GetDeploymentKey() string

func (*GetDeploymentRequest) ProtoMessage 

func (*GetDeploymentRequest) ProtoMessage()

func (*GetDeploymentRequest) ProtoReflect 

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

func (*GetDeploymentRequest) Reset 

func (x *GetDeploymentRequest) Reset()

func (*GetDeploymentRequest) String 

func (x *GetDeploymentRequest) String() string

type GetDeploymentResponse 

type GetDeploymentResponse struct {
	Schema    *schema.Module        `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Artefacts []*DeploymentArtefact `protobuf:"bytes,2,rep,name=artefacts,proto3" json:"artefacts,omitempty"`
	// contains filtered or unexported fields
}

func (*GetDeploymentResponse) Descriptor deprecated 

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

Deprecated: Use GetDeploymentResponse.ProtoReflect.Descriptor instead.

func (*GetDeploymentResponse) GetArtefacts 

func (x *GetDeploymentResponse) GetArtefacts() []*DeploymentArtefact

func (*GetDeploymentResponse) GetSchema 

func (x *GetDeploymentResponse) GetSchema() *schema.Module

func (*GetDeploymentResponse) ProtoMessage 

func (*GetDeploymentResponse) ProtoMessage()

func (*GetDeploymentResponse) ProtoReflect 

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

func (*GetDeploymentResponse) Reset 

func (x *GetDeploymentResponse) Reset()

func (*GetDeploymentResponse) String 

func (x *GetDeploymentResponse) String() string

type GetSchemaRequest 

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

func (*GetSchemaRequest) Descriptor deprecated 

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

Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.

func (*GetSchemaRequest) ProtoMessage 

func (*GetSchemaRequest) ProtoMessage()

func (*GetSchemaRequest) ProtoReflect 

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

func (*GetSchemaRequest) Reset 

func (x *GetSchemaRequest) Reset()

func (*GetSchemaRequest) String 

func (x *GetSchemaRequest) String() string

type GetSchemaResponse 

type GetSchemaResponse struct {
	Schema *schema.Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSchemaResponse) Descriptor deprecated 

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

Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.

func (*GetSchemaResponse) GetSchema 

func (x *GetSchemaResponse) GetSchema() *schema.Schema

func (*GetSchemaResponse) ProtoMessage 

func (*GetSchemaResponse) ProtoMessage()

func (*GetSchemaResponse) ProtoReflect 

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

func (*GetSchemaResponse) Reset 

func (x *GetSchemaResponse) Reset()

func (*GetSchemaResponse) String 

func (x *GetSchemaResponse) String() string

type Metadata 

type Metadata struct {
	Values []*Metadata_Pair `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*Metadata) Add 

func (m *Metadata) Add(key, value string)

func (*Metadata) Delete 

func (m *Metadata) Delete(key string)

func (*Metadata) Descriptor deprecated 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) Get 

func (m *Metadata) Get(key string) optional.Option[string]

func (*Metadata) GetAll 

func (m *Metadata) GetAll(key string) (out []string)

func (*Metadata) GetValues 

func (x *Metadata) GetValues() []*Metadata_Pair

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect 

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

func (*Metadata) Reset 

func (x *Metadata) Reset()

func (*Metadata) Set 

func (m *Metadata) Set(key, value string)

func (*Metadata) String 

func (x *Metadata) String() string

type Metadata_Pair 

type Metadata_Pair 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 (*Metadata_Pair) Descriptor deprecated 

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

Deprecated: Use Metadata_Pair.ProtoReflect.Descriptor instead.

func (*Metadata_Pair) GetKey 

func (x *Metadata_Pair) GetKey() string

func (*Metadata_Pair) GetValue 

func (x *Metadata_Pair) GetValue() string

func (*Metadata_Pair) ProtoMessage 

func (*Metadata_Pair) ProtoMessage()

func (*Metadata_Pair) ProtoReflect 

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

func (*Metadata_Pair) Reset 

func (x *Metadata_Pair) Reset()

func (*Metadata_Pair) String 

func (x *Metadata_Pair) String() string

type ModuleContextRequest added in v0.182.0 

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

func (*ModuleContextRequest) Descriptor deprecated added in v0.182.0 

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

Deprecated: Use ModuleContextRequest.ProtoReflect.Descriptor instead.

func (*ModuleContextRequest) GetModule added in v0.182.0 

func (x *ModuleContextRequest) GetModule() string

func (*ModuleContextRequest) ProtoMessage added in v0.182.0 

func (*ModuleContextRequest) ProtoMessage()

func (*ModuleContextRequest) ProtoReflect added in v0.182.0 

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

func (*ModuleContextRequest) Reset added in v0.182.0 

func (x *ModuleContextRequest) Reset()

func (*ModuleContextRequest) String added in v0.182.0 

func (x *ModuleContextRequest) String() string

type ModuleContextResponse added in v0.182.0 

type ModuleContextResponse struct {
	Module    string                       `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Configs   map[string][]byte            `` /* 155-byte string literal not displayed */
	Secrets   map[string][]byte            `` /* 155-byte string literal not displayed */
	Databases []*ModuleContextResponse_DSN `protobuf:"bytes,4,rep,name=databases,proto3" json:"databases,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleContextResponse) Descriptor deprecated added in v0.182.0 

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

Deprecated: Use ModuleContextResponse.ProtoReflect.Descriptor instead.

func (*ModuleContextResponse) GetConfigs added in v0.182.0 

func (x *ModuleContextResponse) GetConfigs() map[string][]byte

func (*ModuleContextResponse) GetDatabases added in v0.182.0 

func (x *ModuleContextResponse) GetDatabases() []*ModuleContextResponse_DSN

func (*ModuleContextResponse) GetModule added in v0.185.0 

func (x *ModuleContextResponse) GetModule() string

func (*ModuleContextResponse) GetSecrets added in v0.182.0 

func (x *ModuleContextResponse) GetSecrets() map[string][]byte

func (*ModuleContextResponse) ProtoMessage added in v0.182.0 

func (*ModuleContextResponse) ProtoMessage()

func (*ModuleContextResponse) ProtoReflect added in v0.182.0 

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

func (*ModuleContextResponse) Reset added in v0.182.0 

func (x *ModuleContextResponse) Reset()

func (*ModuleContextResponse) String added in v0.182.0 

func (x *ModuleContextResponse) String() string

type ModuleContextResponse_DBType added in v0.182.0 

type ModuleContextResponse_DBType int32
const (
	ModuleContextResponse_POSTGRES ModuleContextResponse_DBType = 0
)

func (ModuleContextResponse_DBType) Descriptor added in v0.182.0 

func (ModuleContextResponse_DBType) Descriptor() protoreflect.EnumDescriptor

func (ModuleContextResponse_DBType) Enum added in v0.182.0 

func (x ModuleContextResponse_DBType) Enum() *ModuleContextResponse_DBType

func (ModuleContextResponse_DBType) EnumDescriptor deprecated added in v0.182.0 

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

Deprecated: Use ModuleContextResponse_DBType.Descriptor instead.

func (ModuleContextResponse_DBType) Number added in v0.182.0 

func (x ModuleContextResponse_DBType) Number() protoreflect.EnumNumber

func (ModuleContextResponse_DBType) String added in v0.182.0 

func (x ModuleContextResponse_DBType) String() string

func (ModuleContextResponse_DBType) Type added in v0.182.0 

func (ModuleContextResponse_DBType) Type() protoreflect.EnumType

type ModuleContextResponse_DSN added in v0.182.0 

type ModuleContextResponse_DSN struct {
	Name string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type ModuleContextResponse_DBType `protobuf:"varint,2,opt,name=type,proto3,enum=xyz.block.ftl.v1.ModuleContextResponse_DBType" json:"type,omitempty"`
	Dsn  string                       `protobuf:"bytes,3,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleContextResponse_DSN) Descriptor deprecated added in v0.182.0 

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

Deprecated: Use ModuleContextResponse_DSN.ProtoReflect.Descriptor instead.

func (*ModuleContextResponse_DSN) GetDsn added in v0.182.0 

func (x *ModuleContextResponse_DSN) GetDsn() string

func (*ModuleContextResponse_DSN) GetName added in v0.182.0 

func (x *ModuleContextResponse_DSN) GetName() string

func (*ModuleContextResponse_DSN) GetType added in v0.182.0 

func (x *ModuleContextResponse_DSN) GetType() ModuleContextResponse_DBType

func (*ModuleContextResponse_DSN) ProtoMessage added in v0.182.0 

func (*ModuleContextResponse_DSN) ProtoMessage()

func (*ModuleContextResponse_DSN) ProtoReflect added in v0.182.0 

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

func (*ModuleContextResponse_DSN) Reset added in v0.182.0 

func (x *ModuleContextResponse_DSN) Reset()

func (*ModuleContextResponse_DSN) String added in v0.182.0 

func (x *ModuleContextResponse_DSN) String() string

type ModuleContextResponse_Ref added in v0.182.0 

type ModuleContextResponse_Ref struct {
	Module *string `protobuf:"bytes,1,opt,name=module,proto3,oneof" json:"module,omitempty"`
	Name   string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*ModuleContextResponse_Ref) Descriptor deprecated added in v0.182.0 

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

Deprecated: Use ModuleContextResponse_Ref.ProtoReflect.Descriptor instead.

func (*ModuleContextResponse_Ref) GetModule added in v0.182.0 

func (x *ModuleContextResponse_Ref) GetModule() string

func (*ModuleContextResponse_Ref) GetName added in v0.182.0 

func (x *ModuleContextResponse_Ref) GetName() string

func (*ModuleContextResponse_Ref) ProtoMessage added in v0.182.0 

func (*ModuleContextResponse_Ref) ProtoMessage()

func (*ModuleContextResponse_Ref) ProtoReflect added in v0.182.0 

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

func (*ModuleContextResponse_Ref) Reset added in v0.182.0 

func (x *ModuleContextResponse_Ref) Reset()

func (*ModuleContextResponse_Ref) String added in v0.182.0 

func (x *ModuleContextResponse_Ref) String() string

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {

	// If present, the service is not ready to accept requests and this is the
	// reason.
	NotReady *string `protobuf:"bytes,1,opt,name=not_ready,json=notReady,proto3,oneof" json:"not_ready,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetNotReady 

func (x *PingResponse) GetNotReady() string

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type ProcessListRequest 

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

func (*ProcessListRequest) Descriptor deprecated 

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

Deprecated: Use ProcessListRequest.ProtoReflect.Descriptor instead.

func (*ProcessListRequest) ProtoMessage 

func (*ProcessListRequest) ProtoMessage()

func (*ProcessListRequest) ProtoReflect 

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

func (*ProcessListRequest) Reset 

func (x *ProcessListRequest) Reset()

func (*ProcessListRequest) String 

func (x *ProcessListRequest) String() string

type ProcessListResponse 

type ProcessListResponse struct {
	Processes []*ProcessListResponse_Process `protobuf:"bytes,1,rep,name=processes,proto3" json:"processes,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessListResponse) Descriptor deprecated 

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

Deprecated: Use ProcessListResponse.ProtoReflect.Descriptor instead.

func (*ProcessListResponse) GetProcesses 

func (x *ProcessListResponse) GetProcesses() []*ProcessListResponse_Process

func (*ProcessListResponse) ProtoMessage 

func (*ProcessListResponse) ProtoMessage()

func (*ProcessListResponse) ProtoReflect 

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

func (*ProcessListResponse) Reset 

func (x *ProcessListResponse) Reset()

func (*ProcessListResponse) String 

func (x *ProcessListResponse) String() string

type ProcessListResponse_Process 

type ProcessListResponse_Process struct {
	Deployment  string                             `protobuf:"bytes,1,opt,name=deployment,proto3" json:"deployment,omitempty"`
	MinReplicas int32                              `protobuf:"varint,2,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	Labels      *structpb.Struct                   `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
	Runner      *ProcessListResponse_ProcessRunner `protobuf:"bytes,4,opt,name=runner,proto3,oneof" json:"runner,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessListResponse_Process) Descriptor deprecated 

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

Deprecated: Use ProcessListResponse_Process.ProtoReflect.Descriptor instead.

func (*ProcessListResponse_Process) GetDeployment 

func (x *ProcessListResponse_Process) GetDeployment() string

func (*ProcessListResponse_Process) GetLabels 

func (x *ProcessListResponse_Process) GetLabels() *structpb.Struct

func (*ProcessListResponse_Process) GetMinReplicas 

func (x *ProcessListResponse_Process) GetMinReplicas() int32

func (*ProcessListResponse_Process) GetRunner 

func (x *ProcessListResponse_Process) GetRunner() *ProcessListResponse_ProcessRunner

func (*ProcessListResponse_Process) ProtoMessage 

func (*ProcessListResponse_Process) ProtoMessage()

func (*ProcessListResponse_Process) ProtoReflect 

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

func (*ProcessListResponse_Process) Reset 

func (x *ProcessListResponse_Process) Reset()

func (*ProcessListResponse_Process) String 

func (x *ProcessListResponse_Process) String() string

type ProcessListResponse_ProcessRunner 

type ProcessListResponse_ProcessRunner struct {
	Key      string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Endpoint string           `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Labels   *structpb.Struct `protobuf:"bytes,3,opt,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessListResponse_ProcessRunner) Descriptor deprecated 

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

Deprecated: Use ProcessListResponse_ProcessRunner.ProtoReflect.Descriptor instead.

func (*ProcessListResponse_ProcessRunner) GetEndpoint 

func (x *ProcessListResponse_ProcessRunner) GetEndpoint() string

func (*ProcessListResponse_ProcessRunner) GetKey 

func (x *ProcessListResponse_ProcessRunner) GetKey() string

func (*ProcessListResponse_ProcessRunner) GetLabels 

func (x *ProcessListResponse_ProcessRunner) GetLabels() *structpb.Struct

func (*ProcessListResponse_ProcessRunner) ProtoMessage 

func (*ProcessListResponse_ProcessRunner) ProtoMessage()

func (*ProcessListResponse_ProcessRunner) ProtoReflect 

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

func (*ProcessListResponse_ProcessRunner) Reset 

func (x *ProcessListResponse_ProcessRunner) Reset()

func (*ProcessListResponse_ProcessRunner) String 

func (x *ProcessListResponse_ProcessRunner) String() string

type PullSchemaRequest 

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

func (*PullSchemaRequest) Descriptor deprecated 

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

Deprecated: Use PullSchemaRequest.ProtoReflect.Descriptor instead.

func (*PullSchemaRequest) ProtoMessage 

func (*PullSchemaRequest) ProtoMessage()

func (*PullSchemaRequest) ProtoReflect 

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

func (*PullSchemaRequest) Reset 

func (x *PullSchemaRequest) Reset()

func (*PullSchemaRequest) String 

func (x *PullSchemaRequest) String() string

type PullSchemaResponse 

type PullSchemaResponse struct {
	DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	ModuleName    string `protobuf:"bytes,2,opt,name=module_name,json=moduleName,proto3" json:"module_name,omitempty"`
	// For deletes this will not be present.
	Schema *schema.Module `protobuf:"bytes,4,opt,name=schema,proto3,oneof" json:"schema,omitempty"`
	// If true there are more schema changes immediately following this one as part of the initial batch.
	// If false this is the last schema change in the initial batch, but others may follow later.
	More       bool                 `protobuf:"varint,3,opt,name=more,proto3" json:"more,omitempty"`
	ChangeType DeploymentChangeType `` /* 135-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*PullSchemaResponse) Descriptor deprecated 

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

Deprecated: Use PullSchemaResponse.ProtoReflect.Descriptor instead.

func (*PullSchemaResponse) GetChangeType 

func (x *PullSchemaResponse) GetChangeType() DeploymentChangeType

func (*PullSchemaResponse) GetDeploymentKey added in v0.151.0 

func (x *PullSchemaResponse) GetDeploymentKey() string

func (*PullSchemaResponse) GetModuleName 

func (x *PullSchemaResponse) GetModuleName() string

func (*PullSchemaResponse) GetMore 

func (x *PullSchemaResponse) GetMore() bool

func (*PullSchemaResponse) GetSchema 

func (x *PullSchemaResponse) GetSchema() *schema.Module

func (*PullSchemaResponse) ProtoMessage 

func (*PullSchemaResponse) ProtoMessage()

func (*PullSchemaResponse) ProtoReflect 

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

func (*PullSchemaResponse) Reset 

func (x *PullSchemaResponse) Reset()

func (*PullSchemaResponse) String 

func (x *PullSchemaResponse) String() string

type RegisterRunnerRequest 

type RegisterRunnerRequest struct {
	Key        string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Endpoint   string           `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Deployment *string          `protobuf:"bytes,3,opt,name=deployment,proto3,oneof" json:"deployment,omitempty"`
	State      RunnerState      `protobuf:"varint,4,opt,name=state,proto3,enum=xyz.block.ftl.v1.RunnerState" json:"state,omitempty"`
	Labels     *structpb.Struct `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	// If present, the reason the Runner is transitioning from ASSIGNED to IDLE.
	Error *string `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRunnerRequest) DeploymentAsOptional 

func (r *RegisterRunnerRequest) DeploymentAsOptional() (optional.Option[model.DeploymentKey], error)

func (*RegisterRunnerRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRunnerRequest.ProtoReflect.Descriptor instead.

func (*RegisterRunnerRequest) GetDeployment 

func (x *RegisterRunnerRequest) GetDeployment() string

func (*RegisterRunnerRequest) GetEndpoint 

func (x *RegisterRunnerRequest) GetEndpoint() string

func (*RegisterRunnerRequest) GetError 

func (x *RegisterRunnerRequest) GetError() string

func (*RegisterRunnerRequest) GetKey 

func (x *RegisterRunnerRequest) GetKey() string

func (*RegisterRunnerRequest) GetLabels 

func (x *RegisterRunnerRequest) GetLabels() *structpb.Struct

func (*RegisterRunnerRequest) GetState 

func (x *RegisterRunnerRequest) GetState() RunnerState

func (*RegisterRunnerRequest) ProtoMessage 

func (*RegisterRunnerRequest) ProtoMessage()

func (*RegisterRunnerRequest) ProtoReflect 

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

func (*RegisterRunnerRequest) Reset 

func (x *RegisterRunnerRequest) Reset()

func (*RegisterRunnerRequest) String 

func (x *RegisterRunnerRequest) String() string

type RegisterRunnerResponse 

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

func (*RegisterRunnerResponse) Descriptor deprecated 

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

Deprecated: Use RegisterRunnerResponse.ProtoReflect.Descriptor instead.

func (*RegisterRunnerResponse) ProtoMessage 

func (*RegisterRunnerResponse) ProtoMessage()

func (*RegisterRunnerResponse) ProtoReflect 

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

func (*RegisterRunnerResponse) Reset 

func (x *RegisterRunnerResponse) Reset()

func (*RegisterRunnerResponse) String 

func (x *RegisterRunnerResponse) String() string

type ReplaceDeployRequest 

type ReplaceDeployRequest struct {
	DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	MinReplicas   int32  `protobuf:"varint,2,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceDeployRequest) Descriptor deprecated 

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

Deprecated: Use ReplaceDeployRequest.ProtoReflect.Descriptor instead.

func (*ReplaceDeployRequest) GetDeploymentKey added in v0.151.0 

func (x *ReplaceDeployRequest) GetDeploymentKey() string

func (*ReplaceDeployRequest) GetMinReplicas 

func (x *ReplaceDeployRequest) GetMinReplicas() int32

func (*ReplaceDeployRequest) ProtoMessage 

func (*ReplaceDeployRequest) ProtoMessage()

func (*ReplaceDeployRequest) ProtoReflect 

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

func (*ReplaceDeployRequest) Reset 

func (x *ReplaceDeployRequest) Reset()

func (*ReplaceDeployRequest) String 

func (x *ReplaceDeployRequest) String() string

type ReplaceDeployResponse 

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

func (*ReplaceDeployResponse) Descriptor deprecated 

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

Deprecated: Use ReplaceDeployResponse.ProtoReflect.Descriptor instead.

func (*ReplaceDeployResponse) ProtoMessage 

func (*ReplaceDeployResponse) ProtoMessage()

func (*ReplaceDeployResponse) ProtoReflect 

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

func (*ReplaceDeployResponse) Reset 

func (x *ReplaceDeployResponse) Reset()

func (*ReplaceDeployResponse) String 

func (x *ReplaceDeployResponse) String() string

type ReserveRequest 

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

func (*ReserveRequest) Descriptor deprecated 

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

Deprecated: Use ReserveRequest.ProtoReflect.Descriptor instead.

func (*ReserveRequest) GetDeploymentKey added in v0.151.0 

func (x *ReserveRequest) GetDeploymentKey() string

func (*ReserveRequest) ProtoMessage 

func (*ReserveRequest) ProtoMessage()

func (*ReserveRequest) ProtoReflect 

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

func (*ReserveRequest) Reset 

func (x *ReserveRequest) Reset()

func (*ReserveRequest) String 

func (x *ReserveRequest) String() string

type ReserveResponse 

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

func (*ReserveResponse) Descriptor deprecated 

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

Deprecated: Use ReserveResponse.ProtoReflect.Descriptor instead.

func (*ReserveResponse) ProtoMessage 

func (*ReserveResponse) ProtoMessage()

func (*ReserveResponse) ProtoReflect 

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

func (*ReserveResponse) Reset 

func (x *ReserveResponse) Reset()

func (*ReserveResponse) String 

func (x *ReserveResponse) String() string

type RunnerState 

type RunnerState int32
const (
	// The Runner is waiting for a deployment.
	RunnerState_RUNNER_IDLE RunnerState = 0
	// The Runner and Controller have agreed that the Runner is reserved.
	RunnerState_RUNNER_RESERVED RunnerState = 1
	// The Runner is assigned to a deployment.
	RunnerState_RUNNER_ASSIGNED RunnerState = 2
	// The Runner is dead.
	RunnerState_RUNNER_DEAD RunnerState = 3
)

func (RunnerState) Descriptor 

func (RunnerState) Descriptor() protoreflect.EnumDescriptor

func (RunnerState) Enum 

func (x RunnerState) Enum() *RunnerState

func (RunnerState) EnumDescriptor deprecated 

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

Deprecated: Use RunnerState.Descriptor instead.

func (RunnerState) Number 

func (x RunnerState) Number() protoreflect.EnumNumber

func (RunnerState) String 

func (x RunnerState) String() string

func (RunnerState) Type 

func (RunnerState) Type() protoreflect.EnumType

type StatusRequest 

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

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Controllers   []*StatusResponse_Controller   `protobuf:"bytes,1,rep,name=controllers,proto3" json:"controllers,omitempty"`
	Runners       []*StatusResponse_Runner       `protobuf:"bytes,2,rep,name=runners,proto3" json:"runners,omitempty"`
	Deployments   []*StatusResponse_Deployment   `protobuf:"bytes,3,rep,name=deployments,proto3" json:"deployments,omitempty"`
	IngressRoutes []*StatusResponse_IngressRoute `protobuf:"bytes,4,rep,name=ingress_routes,json=ingressRoutes,proto3" json:"ingress_routes,omitempty"`
	Routes        []*StatusResponse_Route        `protobuf:"bytes,5,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetControllers 

func (x *StatusResponse) GetControllers() []*StatusResponse_Controller

func (*StatusResponse) GetDeployments 

func (x *StatusResponse) GetDeployments() []*StatusResponse_Deployment

func (*StatusResponse) GetIngressRoutes 

func (x *StatusResponse) GetIngressRoutes() []*StatusResponse_IngressRoute

func (*StatusResponse) GetRoutes 

func (x *StatusResponse) GetRoutes() []*StatusResponse_Route

func (*StatusResponse) GetRunners 

func (x *StatusResponse) GetRunners() []*StatusResponse_Runner

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StatusResponse_Controller 

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

func (*StatusResponse_Controller) Descriptor deprecated 

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

Deprecated: Use StatusResponse_Controller.ProtoReflect.Descriptor instead.

func (*StatusResponse_Controller) GetEndpoint 

func (x *StatusResponse_Controller) GetEndpoint() string

func (*StatusResponse_Controller) GetKey 

func (x *StatusResponse_Controller) GetKey() string

func (*StatusResponse_Controller) ProtoMessage 

func (*StatusResponse_Controller) ProtoMessage()

func (*StatusResponse_Controller) ProtoReflect 

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

func (*StatusResponse_Controller) Reset 

func (x *StatusResponse_Controller) Reset()

func (*StatusResponse_Controller) String 

func (x *StatusResponse_Controller) String() string

type StatusResponse_Deployment 

type StatusResponse_Deployment struct {
	Key         string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Language    string           `protobuf:"bytes,2,opt,name=language,proto3" json:"language,omitempty"`
	Name        string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	MinReplicas int32            `protobuf:"varint,4,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	Replicas    int32            `protobuf:"varint,7,opt,name=replicas,proto3" json:"replicas,omitempty"`
	Labels      *structpb.Struct `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	Schema      *schema.Module   `protobuf:"bytes,6,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_Deployment) Descriptor deprecated 

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

Deprecated: Use StatusResponse_Deployment.ProtoReflect.Descriptor instead.

func (*StatusResponse_Deployment) GetKey 

func (x *StatusResponse_Deployment) GetKey() string

func (*StatusResponse_Deployment) GetLabels 

func (x *StatusResponse_Deployment) GetLabels() *structpb.Struct

func (*StatusResponse_Deployment) GetLanguage 

func (x *StatusResponse_Deployment) GetLanguage() string

func (*StatusResponse_Deployment) GetMinReplicas 

func (x *StatusResponse_Deployment) GetMinReplicas() int32

func (*StatusResponse_Deployment) GetName 

func (x *StatusResponse_Deployment) GetName() string

func (*StatusResponse_Deployment) GetReplicas 

func (x *StatusResponse_Deployment) GetReplicas() int32

func (*StatusResponse_Deployment) GetSchema 

func (x *StatusResponse_Deployment) GetSchema() *schema.Module

func (*StatusResponse_Deployment) ProtoMessage 

func (*StatusResponse_Deployment) ProtoMessage()

func (*StatusResponse_Deployment) ProtoReflect 

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

func (*StatusResponse_Deployment) Reset 

func (x *StatusResponse_Deployment) Reset()

func (*StatusResponse_Deployment) String 

func (x *StatusResponse_Deployment) String() string

type StatusResponse_IngressRoute 

type StatusResponse_IngressRoute struct {
	DeploymentKey string      `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	Verb          *schema.Ref `protobuf:"bytes,5,opt,name=verb,proto3" json:"verb,omitempty"`
	Method        string      `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Path          string      `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_IngressRoute) Descriptor deprecated 

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

Deprecated: Use StatusResponse_IngressRoute.ProtoReflect.Descriptor instead.

func (*StatusResponse_IngressRoute) GetDeploymentKey added in v0.151.0 

func (x *StatusResponse_IngressRoute) GetDeploymentKey() string

func (*StatusResponse_IngressRoute) GetMethod 

func (x *StatusResponse_IngressRoute) GetMethod() string

func (*StatusResponse_IngressRoute) GetPath 

func (x *StatusResponse_IngressRoute) GetPath() string

func (*StatusResponse_IngressRoute) GetVerb 

func (x *StatusResponse_IngressRoute) GetVerb() *schema.Ref

func (*StatusResponse_IngressRoute) ProtoMessage 

func (*StatusResponse_IngressRoute) ProtoMessage()

func (*StatusResponse_IngressRoute) ProtoReflect 

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

func (*StatusResponse_IngressRoute) Reset 

func (x *StatusResponse_IngressRoute) Reset()

func (*StatusResponse_IngressRoute) String 

func (x *StatusResponse_IngressRoute) String() string

type StatusResponse_Route 

type StatusResponse_Route struct {
	Module     string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Runner     string `protobuf:"bytes,2,opt,name=runner,proto3" json:"runner,omitempty"`
	Deployment string `protobuf:"bytes,3,opt,name=deployment,proto3" json:"deployment,omitempty"`
	Endpoint   string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_Route) Descriptor deprecated 

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

Deprecated: Use StatusResponse_Route.ProtoReflect.Descriptor instead.

func (*StatusResponse_Route) GetDeployment 

func (x *StatusResponse_Route) GetDeployment() string

func (*StatusResponse_Route) GetEndpoint 

func (x *StatusResponse_Route) GetEndpoint() string

func (*StatusResponse_Route) GetModule 

func (x *StatusResponse_Route) GetModule() string

func (*StatusResponse_Route) GetRunner 

func (x *StatusResponse_Route) GetRunner() string

func (*StatusResponse_Route) ProtoMessage 

func (*StatusResponse_Route) ProtoMessage()

func (*StatusResponse_Route) ProtoReflect 

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

func (*StatusResponse_Route) Reset 

func (x *StatusResponse_Route) Reset()

func (*StatusResponse_Route) String 

func (x *StatusResponse_Route) String() string

type StatusResponse_Runner 

type StatusResponse_Runner struct {
	Key        string           `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Languages  []string         `protobuf:"bytes,2,rep,name=languages,proto3" json:"languages,omitempty"`
	Endpoint   string           `protobuf:"bytes,3,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	State      RunnerState      `protobuf:"varint,4,opt,name=state,proto3,enum=xyz.block.ftl.v1.RunnerState" json:"state,omitempty"`
	Deployment *string          `protobuf:"bytes,5,opt,name=deployment,proto3,oneof" json:"deployment,omitempty"`
	Labels     *structpb.Struct `protobuf:"bytes,6,opt,name=labels,proto3" json:"labels,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse_Runner) Descriptor deprecated 

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

Deprecated: Use StatusResponse_Runner.ProtoReflect.Descriptor instead.

func (*StatusResponse_Runner) GetDeployment 

func (x *StatusResponse_Runner) GetDeployment() string

func (*StatusResponse_Runner) GetEndpoint 

func (x *StatusResponse_Runner) GetEndpoint() string

func (*StatusResponse_Runner) GetKey 

func (x *StatusResponse_Runner) GetKey() string

func (*StatusResponse_Runner) GetLabels 

func (x *StatusResponse_Runner) GetLabels() *structpb.Struct

func (*StatusResponse_Runner) GetLanguages 

func (x *StatusResponse_Runner) GetLanguages() []string

func (*StatusResponse_Runner) GetState 

func (x *StatusResponse_Runner) GetState() RunnerState

func (*StatusResponse_Runner) ProtoMessage 

func (*StatusResponse_Runner) ProtoMessage()

func (*StatusResponse_Runner) ProtoReflect 

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

func (*StatusResponse_Runner) Reset 

func (x *StatusResponse_Runner) Reset()

func (*StatusResponse_Runner) String 

func (x *StatusResponse_Runner) String() string

type StreamDeploymentLogsRequest 

type StreamDeploymentLogsRequest struct {
	DeploymentKey string                 `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	RequestKey    *string                `protobuf:"bytes,2,opt,name=request_key,json=requestKey,proto3,oneof" json:"request_key,omitempty"`
	TimeStamp     *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=time_stamp,json=timeStamp,proto3" json:"time_stamp,omitempty"`
	LogLevel      int32                  `protobuf:"varint,4,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	Attributes    map[string]string      `` /* 161-byte string literal not displayed */
	Message       string                 `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
	Error         *string                `protobuf:"bytes,7,opt,name=error,proto3,oneof" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamDeploymentLogsRequest) Descriptor deprecated 

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

Deprecated: Use StreamDeploymentLogsRequest.ProtoReflect.Descriptor instead.

func (*StreamDeploymentLogsRequest) GetAttributes 

func (x *StreamDeploymentLogsRequest) GetAttributes() map[string]string

func (*StreamDeploymentLogsRequest) GetDeploymentKey added in v0.151.0 

func (x *StreamDeploymentLogsRequest) GetDeploymentKey() string

func (*StreamDeploymentLogsRequest) GetError 

func (x *StreamDeploymentLogsRequest) GetError() string

func (*StreamDeploymentLogsRequest) GetLogLevel 

func (x *StreamDeploymentLogsRequest) GetLogLevel() int32

func (*StreamDeploymentLogsRequest) GetMessage 

func (x *StreamDeploymentLogsRequest) GetMessage() string

func (*StreamDeploymentLogsRequest) GetRequestKey added in v0.165.1 

func (x *StreamDeploymentLogsRequest) GetRequestKey() string

func (*StreamDeploymentLogsRequest) GetTimeStamp 

func (x *StreamDeploymentLogsRequest) GetTimeStamp() *timestamppb.Timestamp

func (*StreamDeploymentLogsRequest) ProtoMessage 

func (*StreamDeploymentLogsRequest) ProtoMessage()

func (*StreamDeploymentLogsRequest) ProtoReflect 

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

func (*StreamDeploymentLogsRequest) Reset 

func (x *StreamDeploymentLogsRequest) Reset()

func (*StreamDeploymentLogsRequest) String 

func (x *StreamDeploymentLogsRequest) String() string

type StreamDeploymentLogsResponse 

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

func (*StreamDeploymentLogsResponse) Descriptor deprecated 

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

Deprecated: Use StreamDeploymentLogsResponse.ProtoReflect.Descriptor instead.

func (*StreamDeploymentLogsResponse) ProtoMessage 

func (*StreamDeploymentLogsResponse) ProtoMessage()

func (*StreamDeploymentLogsResponse) ProtoReflect 

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

func (*StreamDeploymentLogsResponse) Reset 

func (x *StreamDeploymentLogsResponse) Reset()

func (*StreamDeploymentLogsResponse) String 

func (x *StreamDeploymentLogsResponse) String() string

type TerminateRequest 

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

func (*TerminateRequest) Descriptor deprecated 

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

Deprecated: Use TerminateRequest.ProtoReflect.Descriptor instead.

func (*TerminateRequest) GetDeploymentKey added in v0.151.0 

func (x *TerminateRequest) GetDeploymentKey() string

func (*TerminateRequest) ProtoMessage 

func (*TerminateRequest) ProtoMessage()

func (*TerminateRequest) ProtoReflect 

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

func (*TerminateRequest) Reset 

func (x *TerminateRequest) Reset()

func (*TerminateRequest) String 

func (x *TerminateRequest) String() string

type UpdateDeployRequest 

type UpdateDeployRequest struct {
	DeploymentKey string `protobuf:"bytes,1,opt,name=deployment_key,json=deploymentKey,proto3" json:"deployment_key,omitempty"`
	MinReplicas   int32  `protobuf:"varint,2,opt,name=min_replicas,json=minReplicas,proto3" json:"min_replicas,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateDeployRequest) Descriptor deprecated 

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

Deprecated: Use UpdateDeployRequest.ProtoReflect.Descriptor instead.

func (*UpdateDeployRequest) GetDeploymentKey added in v0.151.0 

func (x *UpdateDeployRequest) GetDeploymentKey() string

func (*UpdateDeployRequest) GetMinReplicas 

func (x *UpdateDeployRequest) GetMinReplicas() int32

func (*UpdateDeployRequest) ProtoMessage 

func (*UpdateDeployRequest) ProtoMessage()

func (*UpdateDeployRequest) ProtoReflect 

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

func (*UpdateDeployRequest) Reset 

func (x *UpdateDeployRequest) Reset()

func (*UpdateDeployRequest) String 

func (x *UpdateDeployRequest) String() string

type UpdateDeployResponse 

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

func (*UpdateDeployResponse) Descriptor deprecated 

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

Deprecated: Use UpdateDeployResponse.ProtoReflect.Descriptor instead.

func (*UpdateDeployResponse) ProtoMessage 

func (*UpdateDeployResponse) ProtoMessage()

func (*UpdateDeployResponse) ProtoReflect 

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

func (*UpdateDeployResponse) Reset 

func (x *UpdateDeployResponse) Reset()

func (*UpdateDeployResponse) String 

func (x *UpdateDeployResponse) String() string

type UploadArtefactRequest 

type UploadArtefactRequest struct {
	Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadArtefactRequest) Descriptor deprecated 

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

Deprecated: Use UploadArtefactRequest.ProtoReflect.Descriptor instead.

func (*UploadArtefactRequest) GetContent 

func (x *UploadArtefactRequest) GetContent() []byte

func (*UploadArtefactRequest) ProtoMessage 

func (*UploadArtefactRequest) ProtoMessage()

func (*UploadArtefactRequest) ProtoReflect 

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

func (*UploadArtefactRequest) Reset 

func (x *UploadArtefactRequest) Reset()

func (*UploadArtefactRequest) String 

func (x *UploadArtefactRequest) String() string

type UploadArtefactResponse 

type UploadArtefactResponse struct {
	Digest []byte `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadArtefactResponse) Descriptor deprecated 

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

Deprecated: Use UploadArtefactResponse.ProtoReflect.Descriptor instead.

func (*UploadArtefactResponse) GetDigest 

func (x *UploadArtefactResponse) GetDigest() []byte

func (*UploadArtefactResponse) ProtoMessage 

func (*UploadArtefactResponse) ProtoMessage()

func (*UploadArtefactResponse) ProtoReflect 

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

func (*UploadArtefactResponse) Reset 

func (x *UploadArtefactResponse) Reset()

func (*UploadArtefactResponse) String 

func (x *UploadArtefactResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis
pbconsoleconnect

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.