orchestrationpb

package
v0.0.0-...-7cc9995 Latest Latest
Warning

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

 Go to latest Published: Nov 4, 2024 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_proto_orchestrationpb_orchestration_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ClientOpts 

type ClientOpts struct {

	// The client's ID.
	ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// Determines whether TLS should be used.
	UseTLS bool `protobuf:"varint,4,opt,name=UseTLS,proto3" json:"UseTLS,omitempty"`
	// The maximum number of concurrent requests.
	MaxConcurrent uint32 `protobuf:"varint,8,opt,name=MaxConcurrent,proto3" json:"MaxConcurrent,omitempty"`
	// The size in bytes of each command.
	PayloadSize uint32 `protobuf:"varint,9,opt,name=PayloadSize,proto3" json:"PayloadSize,omitempty"`
	// The timeout of the initial connection.
	ConnectTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=ConnectTimeout,proto3" json:"ConnectTimeout,omitempty"`
	// The limit on how many commands can be sent per second.
	RateLimit float64 `protobuf:"fixed64,11,opt,name=RateLimit,proto3" json:"RateLimit,omitempty"`
	// The amount of commands per second to increase the rate limit by.
	RateStep float64 `protobuf:"fixed64,12,opt,name=RateStep,proto3" json:"RateStep,omitempty"`
	// How often to increase the rate limit.
	RateStepInterval *durationpb.Duration `protobuf:"bytes,13,opt,name=RateStepInterval,proto3" json:"RateStepInterval,omitempty"`
	// The timeout for a command.
	Timeout *durationpb.Duration `protobuf:"bytes,14,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientOpts) Descriptor deprecated 

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

Deprecated: Use ClientOpts.ProtoReflect.Descriptor instead.

func (*ClientOpts) GetConnectTimeout 

func (x *ClientOpts) GetConnectTimeout() *durationpb.Duration

func (*ClientOpts) GetID 

func (x *ClientOpts) GetID() uint32

func (*ClientOpts) GetMaxConcurrent 

func (x *ClientOpts) GetMaxConcurrent() uint32

func (*ClientOpts) GetPayloadSize 

func (x *ClientOpts) GetPayloadSize() uint32

func (*ClientOpts) GetRateLimit 

func (x *ClientOpts) GetRateLimit() float64

func (*ClientOpts) GetRateStep 

func (x *ClientOpts) GetRateStep() float64

func (*ClientOpts) GetRateStepInterval 

func (x *ClientOpts) GetRateStepInterval() *durationpb.Duration

func (*ClientOpts) GetTimeout 

func (x *ClientOpts) GetTimeout() *durationpb.Duration

func (*ClientOpts) GetUseTLS 

func (x *ClientOpts) GetUseTLS() bool

func (*ClientOpts) ProtoMessage 

func (*ClientOpts) ProtoMessage()

func (*ClientOpts) ProtoReflect 

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

func (*ClientOpts) Reset 

func (x *ClientOpts) Reset()

func (*ClientOpts) String 

func (x *ClientOpts) String() string

type CreateReplicaRequest 

type CreateReplicaRequest struct {
	Replicas map[uint32]*ReplicaOpts `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateReplicaRequest) Descriptor deprecated 

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

Deprecated: Use CreateReplicaRequest.ProtoReflect.Descriptor instead.

func (*CreateReplicaRequest) GetReplicas 

func (x *CreateReplicaRequest) GetReplicas() map[uint32]*ReplicaOpts

func (*CreateReplicaRequest) ProtoMessage 

func (*CreateReplicaRequest) ProtoMessage()

func (*CreateReplicaRequest) ProtoReflect 

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

func (*CreateReplicaRequest) Reset 

func (x *CreateReplicaRequest) Reset()

func (*CreateReplicaRequest) String 

func (x *CreateReplicaRequest) String() string

type CreateReplicaResponse 

type CreateReplicaResponse struct {
	Replicas map[uint32]*ReplicaInfo `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CreateReplicaResponse) Descriptor deprecated 

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

Deprecated: Use CreateReplicaResponse.ProtoReflect.Descriptor instead.

func (*CreateReplicaResponse) GetReplicas 

func (x *CreateReplicaResponse) GetReplicas() map[uint32]*ReplicaInfo

func (*CreateReplicaResponse) ProtoMessage 

func (*CreateReplicaResponse) ProtoMessage()

func (*CreateReplicaResponse) ProtoReflect 

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

func (*CreateReplicaResponse) Reset 

func (x *CreateReplicaResponse) Reset()

func (*CreateReplicaResponse) String 

func (x *CreateReplicaResponse) String() string

type QuitRequest 

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

func (*QuitRequest) Descriptor deprecated 

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

Deprecated: Use QuitRequest.ProtoReflect.Descriptor instead.

func (*QuitRequest) ProtoMessage 

func (*QuitRequest) ProtoMessage()

func (*QuitRequest) ProtoReflect 

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

func (*QuitRequest) Reset 

func (x *QuitRequest) Reset()

func (*QuitRequest) String 

func (x *QuitRequest) String() string

type ReplicaConfiguration 

type ReplicaConfiguration struct {
	Replicas map[uint32]*ReplicaInfo `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ReplicaConfiguration) Descriptor deprecated 

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

Deprecated: Use ReplicaConfiguration.ProtoReflect.Descriptor instead.

func (*ReplicaConfiguration) GetReplicas 

func (x *ReplicaConfiguration) GetReplicas() map[uint32]*ReplicaInfo

func (*ReplicaConfiguration) ProtoMessage 

func (*ReplicaConfiguration) ProtoMessage()

func (*ReplicaConfiguration) ProtoReflect 

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

func (*ReplicaConfiguration) Reset 

func (x *ReplicaConfiguration) Reset()

func (*ReplicaConfiguration) String 

func (x *ReplicaConfiguration) String() string

type ReplicaInfo 

type ReplicaInfo struct {

	// The ID of the replica.
	ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// The IP address of the replica.
	Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
	// The public key of the replica.
	PublicKey []byte `protobuf:"bytes,3,opt,name=PublicKey,proto3" json:"PublicKey,omitempty"`
	// The port that other replicas should connect to.
	ReplicaPort uint32 `protobuf:"varint,4,opt,name=ReplicaPort,proto3" json:"ReplicaPort,omitempty"`
	// The port that clients should connect to.
	ClientPort uint32 `protobuf:"varint,5,opt,name=ClientPort,proto3" json:"ClientPort,omitempty"`
	// contains filtered or unexported fields
}

ReplicaInfo is the information that the replicas need about each other.

func (*ReplicaInfo) Descriptor deprecated 

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

Deprecated: Use ReplicaInfo.ProtoReflect.Descriptor instead.

func (*ReplicaInfo) GetAddress 

func (x *ReplicaInfo) GetAddress() string

func (*ReplicaInfo) GetClientPort 

func (x *ReplicaInfo) GetClientPort() uint32

func (*ReplicaInfo) GetID 

func (x *ReplicaInfo) GetID() uint32

func (*ReplicaInfo) GetPublicKey 

func (x *ReplicaInfo) GetPublicKey() []byte

func (*ReplicaInfo) GetReplicaPort 

func (x *ReplicaInfo) GetReplicaPort() uint32

func (*ReplicaInfo) ProtoMessage 

func (*ReplicaInfo) ProtoMessage()

func (*ReplicaInfo) ProtoReflect 

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

func (*ReplicaInfo) Reset 

func (x *ReplicaInfo) Reset()

func (*ReplicaInfo) String 

func (x *ReplicaInfo) String() string

type ReplicaOpts 

type ReplicaOpts struct {

	// The replica's ID.
	ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	// The replica's private key.
	PrivateKey []byte `protobuf:"bytes,3,opt,name=PrivateKey,proto3" json:"PrivateKey,omitempty"`
	// The replica's public key.
	PublicKey []byte `protobuf:"bytes,16,opt,name=PublicKey,proto3" json:"PublicKey,omitempty"`
	// Determines whether TLS should be used.
	UseTLS bool `protobuf:"varint,4,opt,name=UseTLS,proto3" json:"UseTLS,omitempty"`
	// The replica's TLS certificate.
	Certificate []byte `protobuf:"bytes,5,opt,name=Certificate,proto3" json:"Certificate,omitempty"`
	// The private key of the TLS certificate.
	CertificateKey []byte `protobuf:"bytes,6,opt,name=CertificateKey,proto3" json:"CertificateKey,omitempty"`
	// The certificate authority that created the TLS certificates.
	CertificateAuthority []byte `protobuf:"bytes,7,opt,name=CertificateAuthority,proto3" json:"CertificateAuthority,omitempty"`
	// The name of the crypto implementation to use.
	Crypto string `protobuf:"bytes,8,opt,name=Crypto,proto3" json:"Crypto,omitempty"`
	// The name of the consensus implementation to use.
	Consensus string `protobuf:"bytes,9,opt,name=Consensus,proto3" json:"Consensus,omitempty"`
	// The name of the leader rotation algorithm to use.
	LeaderRotation string `protobuf:"bytes,10,opt,name=LeaderRotation,proto3" json:"LeaderRotation,omitempty"`
	// The number of client commands that should be batched together.
	BatchSize uint32 `protobuf:"varint,11,opt,name=BatchSize,proto3" json:"BatchSize,omitempty"`
	// The timeout of the initial connection setup.
	ConnectTimeout *durationpb.Duration `protobuf:"bytes,17,opt,name=ConnectTimeout,proto3" json:"ConnectTimeout,omitempty"`
	// The initial view duration.
	InitialTimeout *durationpb.Duration `protobuf:"bytes,12,opt,name=InitialTimeout,proto3" json:"InitialTimeout,omitempty"`
	// The maximum view timeout.
	MaxTimeout *durationpb.Duration `protobuf:"bytes,19,opt,name=MaxTimeout,proto3" json:"MaxTimeout,omitempty"`
	// The number of samples used to calculate view duration.
	TimeoutSamples uint32 `protobuf:"varint,13,opt,name=TimeoutSamples,proto3" json:"TimeoutSamples,omitempty"`
	// The number that the old view duration should be multiplied by when a new
	// timeout happens.
	TimeoutMultiplier float32 `protobuf:"fixed32,14,opt,name=TimeoutMultiplier,proto3" json:"TimeoutMultiplier,omitempty"`
	// The byzantine strategy to use. If empty, the replica will act normally.
	ByzantineStrategy string `protobuf:"bytes,18,opt,name=ByzantineStrategy,proto3" json:"ByzantineStrategy,omitempty"`
	// A shared random number for seeding random number generators.
	SharedSeed int64 `protobuf:"varint,20,opt,name=SharedSeed,proto3" json:"SharedSeed,omitempty"`
	// A list of modules to load.
	Modules []string `protobuf:"bytes,21,rep,name=Modules,proto3" json:"Modules,omitempty"`
	// locations of the replicas
	LocationInfo map[uint32]string `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

ReplicaOpts contains the confiugration options for a replica.

func (*ReplicaOpts) Descriptor deprecated 

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

Deprecated: Use ReplicaOpts.ProtoReflect.Descriptor instead.

func (*ReplicaOpts) GetBatchSize 

func (x *ReplicaOpts) GetBatchSize() uint32

func (*ReplicaOpts) GetByzantineStrategy 

func (x *ReplicaOpts) GetByzantineStrategy() string

func (*ReplicaOpts) GetCertificate 

func (x *ReplicaOpts) GetCertificate() []byte

func (*ReplicaOpts) GetCertificateAuthority 

func (x *ReplicaOpts) GetCertificateAuthority() []byte

func (*ReplicaOpts) GetCertificateKey 

func (x *ReplicaOpts) GetCertificateKey() []byte

func (*ReplicaOpts) GetConnectTimeout 

func (x *ReplicaOpts) GetConnectTimeout() *durationpb.Duration

func (*ReplicaOpts) GetConsensus 

func (x *ReplicaOpts) GetConsensus() string

func (*ReplicaOpts) GetCrypto 

func (x *ReplicaOpts) GetCrypto() string

func (*ReplicaOpts) GetID 

func (x *ReplicaOpts) GetID() uint32

func (*ReplicaOpts) GetInitialTimeout 

func (x *ReplicaOpts) GetInitialTimeout() *durationpb.Duration

func (*ReplicaOpts) GetLeaderRotation 

func (x *ReplicaOpts) GetLeaderRotation() string

func (*ReplicaOpts) GetLocationInfo 

func (x *ReplicaOpts) GetLocationInfo() map[uint32]string

func (*ReplicaOpts) GetMaxTimeout 

func (x *ReplicaOpts) GetMaxTimeout() *durationpb.Duration

func (*ReplicaOpts) GetModules 

func (x *ReplicaOpts) GetModules() []string

func (*ReplicaOpts) GetPrivateKey 

func (x *ReplicaOpts) GetPrivateKey() []byte

func (*ReplicaOpts) GetPublicKey 

func (x *ReplicaOpts) GetPublicKey() []byte

func (*ReplicaOpts) GetSharedSeed 

func (x *ReplicaOpts) GetSharedSeed() int64

func (*ReplicaOpts) GetTimeoutMultiplier 

func (x *ReplicaOpts) GetTimeoutMultiplier() float32

func (*ReplicaOpts) GetTimeoutSamples 

func (x *ReplicaOpts) GetTimeoutSamples() uint32

func (*ReplicaOpts) GetUseTLS 

func (x *ReplicaOpts) GetUseTLS() bool

func (*ReplicaOpts) ProtoMessage 

func (*ReplicaOpts) ProtoMessage()

func (*ReplicaOpts) ProtoReflect 

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

func (*ReplicaOpts) Reset 

func (x *ReplicaOpts) Reset()

func (*ReplicaOpts) String 

func (x *ReplicaOpts) String() string

type StartClientRequest 

type StartClientRequest struct {

	// The clients to create.
	Clients map[uint32]*ClientOpts `` /* 156-byte string literal not displayed */
	// The certificate authority that created the TLS certificates.
	CertificateAuthority []byte `protobuf:"bytes,7,opt,name=CertificateAuthority,proto3" json:"CertificateAuthority,omitempty"`
	// The replicas to connect to.
	Configuration map[uint32]*ReplicaInfo `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartClientRequest) Descriptor deprecated 

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

Deprecated: Use StartClientRequest.ProtoReflect.Descriptor instead.

func (*StartClientRequest) GetCertificateAuthority 

func (x *StartClientRequest) GetCertificateAuthority() []byte

func (*StartClientRequest) GetClients 

func (x *StartClientRequest) GetClients() map[uint32]*ClientOpts

func (*StartClientRequest) GetConfiguration 

func (x *StartClientRequest) GetConfiguration() map[uint32]*ReplicaInfo

func (*StartClientRequest) ProtoMessage 

func (*StartClientRequest) ProtoMessage()

func (*StartClientRequest) ProtoReflect 

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

func (*StartClientRequest) Reset 

func (x *StartClientRequest) Reset()

func (*StartClientRequest) String 

func (x *StartClientRequest) String() string

type StartClientResponse 

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

func (*StartClientResponse) Descriptor deprecated 

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

Deprecated: Use StartClientResponse.ProtoReflect.Descriptor instead.

func (*StartClientResponse) ProtoMessage 

func (*StartClientResponse) ProtoMessage()

func (*StartClientResponse) ProtoReflect 

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

func (*StartClientResponse) Reset 

func (x *StartClientResponse) Reset()

func (*StartClientResponse) String 

func (x *StartClientResponse) String() string

type StartReplicaRequest 

type StartReplicaRequest struct {

	// The replica IDs that should be started.
	IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	// The configuration of replicas to connect to.
	Configuration map[uint32]*ReplicaInfo `` /* 168-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartReplicaRequest) Descriptor deprecated 

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

Deprecated: Use StartReplicaRequest.ProtoReflect.Descriptor instead.

func (*StartReplicaRequest) GetConfiguration 

func (x *StartReplicaRequest) GetConfiguration() map[uint32]*ReplicaInfo

func (*StartReplicaRequest) GetIDs 

func (x *StartReplicaRequest) GetIDs() []uint32

func (*StartReplicaRequest) ProtoMessage 

func (*StartReplicaRequest) ProtoMessage()

func (*StartReplicaRequest) ProtoReflect 

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

func (*StartReplicaRequest) Reset 

func (x *StartReplicaRequest) Reset()

func (*StartReplicaRequest) String 

func (x *StartReplicaRequest) String() string

type StartReplicaResponse 

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

func (*StartReplicaResponse) Descriptor deprecated 

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

Deprecated: Use StartReplicaResponse.ProtoReflect.Descriptor instead.

func (*StartReplicaResponse) ProtoMessage 

func (*StartReplicaResponse) ProtoMessage()

func (*StartReplicaResponse) ProtoReflect 

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

func (*StartReplicaResponse) Reset 

func (x *StartReplicaResponse) Reset()

func (*StartReplicaResponse) String 

func (x *StartReplicaResponse) String() string

type StopClientRequest 

type StopClientRequest struct {
	IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	// contains filtered or unexported fields
}

func (*StopClientRequest) Descriptor deprecated 

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

Deprecated: Use StopClientRequest.ProtoReflect.Descriptor instead.

func (*StopClientRequest) GetIDs 

func (x *StopClientRequest) GetIDs() []uint32

func (*StopClientRequest) ProtoMessage 

func (*StopClientRequest) ProtoMessage()

func (*StopClientRequest) ProtoReflect 

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

func (*StopClientRequest) Reset 

func (x *StopClientRequest) Reset()

func (*StopClientRequest) String 

func (x *StopClientRequest) String() string

type StopClientResponse 

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

func (*StopClientResponse) Descriptor deprecated 

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

Deprecated: Use StopClientResponse.ProtoReflect.Descriptor instead.

func (*StopClientResponse) ProtoMessage 

func (*StopClientResponse) ProtoMessage()

func (*StopClientResponse) ProtoReflect 

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

func (*StopClientResponse) Reset 

func (x *StopClientResponse) Reset()

func (*StopClientResponse) String 

func (x *StopClientResponse) String() string

type StopReplicaRequest 

type StopReplicaRequest struct {
	IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
	// contains filtered or unexported fields
}

func (*StopReplicaRequest) Descriptor deprecated 

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

Deprecated: Use StopReplicaRequest.ProtoReflect.Descriptor instead.

func (*StopReplicaRequest) GetIDs 

func (x *StopReplicaRequest) GetIDs() []uint32

func (*StopReplicaRequest) ProtoMessage 

func (*StopReplicaRequest) ProtoMessage()

func (*StopReplicaRequest) ProtoReflect 

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

func (*StopReplicaRequest) Reset 

func (x *StopReplicaRequest) Reset()

func (*StopReplicaRequest) String 

func (x *StopReplicaRequest) String() string

type StopReplicaResponse 

type StopReplicaResponse struct {

	// The final state hash of all executed commands
	Hashes map[uint32][]byte `` /* 154-byte string literal not displayed */
	// The final count of executed commands
	Counts map[uint32]uint32 `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StopReplicaResponse) Descriptor deprecated 

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

Deprecated: Use StopReplicaResponse.ProtoReflect.Descriptor instead.

func (*StopReplicaResponse) GetCounts 

func (x *StopReplicaResponse) GetCounts() map[uint32]uint32

func (*StopReplicaResponse) GetHashes 

func (x *StopReplicaResponse) GetHashes() map[uint32][]byte

func (*StopReplicaResponse) ProtoMessage 

func (*StopReplicaResponse) ProtoMessage()

func (*StopReplicaResponse) ProtoReflect 

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

func (*StopReplicaResponse) Reset 

func (x *StopReplicaResponse) Reset()

func (*StopReplicaResponse) String 

func (x *StopReplicaResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.