v1

package
v0.8.0 Latest Latest
Warning

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

 Go to latest Published: Nov 21, 2021 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConfig = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterProtocolConfigServiceServer 

func RegisterProtocolConfigServiceServer(s *grpc.Server, srv ProtocolConfigServiceServer)

Types

type ProtocolConfig 

type ProtocolConfig struct {
	// nodes is a list of replicas
	Replicas []ProtocolReplica `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas"`
	// partitions is a list of partitions owned by the replicas
	Partitions []ProtocolPartition `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions"`
}

Protocol configuration

func (*ProtocolConfig) Descriptor 

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

func (*ProtocolConfig) GetPartitions 

func (m *ProtocolConfig) GetPartitions() []ProtocolPartition

func (*ProtocolConfig) GetReplicas 

func (m *ProtocolConfig) GetReplicas() []ProtocolReplica

func (*ProtocolConfig) Marshal 

func (m *ProtocolConfig) Marshal() (dAtA []byte, err error)

func (*ProtocolConfig) MarshalTo 

func (m *ProtocolConfig) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolConfig) MarshalToSizedBuffer 

func (m *ProtocolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolConfig) ProtoMessage 

func (*ProtocolConfig) ProtoMessage()

func (*ProtocolConfig) Reset 

func (m *ProtocolConfig) Reset()

func (*ProtocolConfig) Size 

func (m *ProtocolConfig) Size() (n int)

func (*ProtocolConfig) String 

func (m *ProtocolConfig) String() string

func (*ProtocolConfig) Unmarshal 

func (m *ProtocolConfig) Unmarshal(dAtA []byte) error

func (*ProtocolConfig) XXX_DiscardUnknown 

func (m *ProtocolConfig) XXX_DiscardUnknown()

func (*ProtocolConfig) XXX_Marshal 

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

func (*ProtocolConfig) XXX_Merge 

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

func (*ProtocolConfig) XXX_Size 

func (m *ProtocolConfig) XXX_Size() int

func (*ProtocolConfig) XXX_Unmarshal 

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

type ProtocolConfigServiceClient 

type ProtocolConfigServiceClient interface {
	// UpdateConfig updates the protocol configuration
	UpdateConfig(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error)
}

ProtocolConfigServiceClient is the client API for ProtocolConfigService service.

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

func NewProtocolConfigServiceClient 

func NewProtocolConfigServiceClient(cc *grpc.ClientConn) ProtocolConfigServiceClient

type ProtocolConfigServiceServer 

type ProtocolConfigServiceServer interface {
	// UpdateConfig updates the protocol configuration
	UpdateConfig(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error)
}

ProtocolConfigServiceServer is the server API for ProtocolConfigService service.

type ProtocolId 

type ProtocolId struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

Protocol identifier

func (*ProtocolId) Descriptor 

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

func (*ProtocolId) GetName 

func (m *ProtocolId) GetName() string

func (*ProtocolId) GetNamespace 

func (m *ProtocolId) GetNamespace() string

func (*ProtocolId) Marshal 

func (m *ProtocolId) Marshal() (dAtA []byte, err error)

func (*ProtocolId) MarshalTo 

func (m *ProtocolId) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolId) MarshalToSizedBuffer 

func (m *ProtocolId) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolId) ProtoMessage 

func (*ProtocolId) ProtoMessage()

func (*ProtocolId) Reset 

func (m *ProtocolId) Reset()

func (*ProtocolId) Size 

func (m *ProtocolId) Size() (n int)

func (*ProtocolId) String 

func (m *ProtocolId) String() string

func (*ProtocolId) Unmarshal 

func (m *ProtocolId) Unmarshal(dAtA []byte) error

func (*ProtocolId) XXX_DiscardUnknown 

func (m *ProtocolId) XXX_DiscardUnknown()

func (*ProtocolId) XXX_Marshal 

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

func (*ProtocolId) XXX_Merge 

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

func (*ProtocolId) XXX_Size 

func (m *ProtocolId) XXX_Size() int

func (*ProtocolId) XXX_Unmarshal 

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

type ProtocolPartition 

type ProtocolPartition struct {
	PartitionID  uint32   `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Replicas     []string `protobuf:"bytes,2,rep,name=replicas,proto3" json:"replicas,omitempty"`
	Host         string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	APIPort      int32    `protobuf:"varint,4,opt,name=api_port,json=apiPort,proto3" json:"apiPort"`
	ReadReplicas []string `protobuf:"bytes,5,rep,name=read_replicas,json=readReplicas,proto3" json:"read_replicas,omitempty"`
}

Partition info

func (*ProtocolPartition) Descriptor 

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

func (*ProtocolPartition) GetAPIPort 

func (m *ProtocolPartition) GetAPIPort() int32

func (*ProtocolPartition) GetHost 

func (m *ProtocolPartition) GetHost() string

func (*ProtocolPartition) GetPartitionID 

func (m *ProtocolPartition) GetPartitionID() uint32

func (*ProtocolPartition) GetReadReplicas 

func (m *ProtocolPartition) GetReadReplicas() []string

func (*ProtocolPartition) GetReplicas 

func (m *ProtocolPartition) GetReplicas() []string

func (*ProtocolPartition) Marshal 

func (m *ProtocolPartition) Marshal() (dAtA []byte, err error)

func (*ProtocolPartition) MarshalTo 

func (m *ProtocolPartition) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolPartition) MarshalToSizedBuffer 

func (m *ProtocolPartition) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolPartition) ProtoMessage 

func (*ProtocolPartition) ProtoMessage()

func (*ProtocolPartition) Reset 

func (m *ProtocolPartition) Reset()

func (*ProtocolPartition) Size 

func (m *ProtocolPartition) Size() (n int)

func (*ProtocolPartition) String 

func (m *ProtocolPartition) String() string

func (*ProtocolPartition) Unmarshal 

func (m *ProtocolPartition) Unmarshal(dAtA []byte) error

func (*ProtocolPartition) XXX_DiscardUnknown 

func (m *ProtocolPartition) XXX_DiscardUnknown()

func (*ProtocolPartition) XXX_Marshal 

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

func (*ProtocolPartition) XXX_Merge 

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

func (*ProtocolPartition) XXX_Size 

func (m *ProtocolPartition) XXX_Size() int

func (*ProtocolPartition) XXX_Unmarshal 

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

type ProtocolReplica 

type ProtocolReplica struct {
	// id is the unique member identifier
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// node_id is the ID of the node on which the replica is deployed
	NodeID string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// host is the member host
	Host string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	// api_port is the port to use for the client API
	APIPort int32 `protobuf:"varint,4,opt,name=api_port,json=apiPort,proto3" json:"apiPort"`
	// extra_ports is a set of named ports
	ExtraPorts map[string]int32 `` /* 180-byte string literal not displayed */
}

Replica configuration

func (*ProtocolReplica) Descriptor 

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

func (*ProtocolReplica) GetAPIPort 

func (m *ProtocolReplica) GetAPIPort() int32

func (*ProtocolReplica) GetExtraPorts 

func (m *ProtocolReplica) GetExtraPorts() map[string]int32

func (*ProtocolReplica) GetHost 

func (m *ProtocolReplica) GetHost() string

func (*ProtocolReplica) GetID 

func (m *ProtocolReplica) GetID() string

func (*ProtocolReplica) GetNodeID 

func (m *ProtocolReplica) GetNodeID() string

func (*ProtocolReplica) Marshal 

func (m *ProtocolReplica) Marshal() (dAtA []byte, err error)

func (*ProtocolReplica) MarshalTo 

func (m *ProtocolReplica) MarshalTo(dAtA []byte) (int, error)

func (*ProtocolReplica) MarshalToSizedBuffer 

func (m *ProtocolReplica) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProtocolReplica) ProtoMessage 

func (*ProtocolReplica) ProtoMessage()

func (*ProtocolReplica) Reset 

func (m *ProtocolReplica) Reset()

func (*ProtocolReplica) Size 

func (m *ProtocolReplica) Size() (n int)

func (*ProtocolReplica) String 

func (m *ProtocolReplica) String() string

func (*ProtocolReplica) Unmarshal 

func (m *ProtocolReplica) Unmarshal(dAtA []byte) error

func (*ProtocolReplica) XXX_DiscardUnknown 

func (m *ProtocolReplica) XXX_DiscardUnknown()

func (*ProtocolReplica) XXX_Marshal 

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

func (*ProtocolReplica) XXX_Merge 

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

func (*ProtocolReplica) XXX_Size 

func (m *ProtocolReplica) XXX_Size() int

func (*ProtocolReplica) XXX_Unmarshal 

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

type UnimplementedProtocolConfigServiceServer 

type UnimplementedProtocolConfigServiceServer struct {
}

UnimplementedProtocolConfigServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedProtocolConfigServiceServer) UpdateConfig 

func (*UnimplementedProtocolConfigServiceServer) UpdateConfig(ctx context.Context, req *UpdateConfigRequest) (*UpdateConfigResponse, error)

type UpdateConfigRequest 

type UpdateConfigRequest struct {
	Config ProtocolConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config"`
}

func (*UpdateConfigRequest) Descriptor 

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

func (*UpdateConfigRequest) GetConfig 

func (m *UpdateConfigRequest) GetConfig() ProtocolConfig

func (*UpdateConfigRequest) Marshal 

func (m *UpdateConfigRequest) Marshal() (dAtA []byte, err error)

func (*UpdateConfigRequest) MarshalTo 

func (m *UpdateConfigRequest) MarshalTo(dAtA []byte) (int, error)

func (*UpdateConfigRequest) MarshalToSizedBuffer 

func (m *UpdateConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateConfigRequest) ProtoMessage 

func (*UpdateConfigRequest) ProtoMessage()

func (*UpdateConfigRequest) Reset 

func (m *UpdateConfigRequest) Reset()

func (*UpdateConfigRequest) Size 

func (m *UpdateConfigRequest) Size() (n int)

func (*UpdateConfigRequest) String 

func (m *UpdateConfigRequest) String() string

func (*UpdateConfigRequest) Unmarshal 

func (m *UpdateConfigRequest) Unmarshal(dAtA []byte) error

func (*UpdateConfigRequest) XXX_DiscardUnknown 

func (m *UpdateConfigRequest) XXX_DiscardUnknown()

func (*UpdateConfigRequest) XXX_Marshal 

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

func (*UpdateConfigRequest) XXX_Merge 

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

func (*UpdateConfigRequest) XXX_Size 

func (m *UpdateConfigRequest) XXX_Size() int

func (*UpdateConfigRequest) XXX_Unmarshal 

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

type UpdateConfigResponse 

type UpdateConfigResponse struct {
}

func (*UpdateConfigResponse) Descriptor 

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

func (*UpdateConfigResponse) Marshal 

func (m *UpdateConfigResponse) Marshal() (dAtA []byte, err error)

func (*UpdateConfigResponse) MarshalTo 

func (m *UpdateConfigResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateConfigResponse) MarshalToSizedBuffer 

func (m *UpdateConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateConfigResponse) ProtoMessage 

func (*UpdateConfigResponse) ProtoMessage()

func (*UpdateConfigResponse) Reset 

func (m *UpdateConfigResponse) Reset()

func (*UpdateConfigResponse) Size 

func (m *UpdateConfigResponse) Size() (n int)

func (*UpdateConfigResponse) String 

func (m *UpdateConfigResponse) String() string

func (*UpdateConfigResponse) Unmarshal 

func (m *UpdateConfigResponse) Unmarshal(dAtA []byte) error

func (*UpdateConfigResponse) XXX_DiscardUnknown 

func (m *UpdateConfigResponse) XXX_DiscardUnknown()

func (*UpdateConfigResponse) XXX_Marshal 

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

func (*UpdateConfigResponse) XXX_Merge 

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

func (*UpdateConfigResponse) XXX_Size 

func (m *UpdateConfigResponse) XXX_Size() int

func (*UpdateConfigResponse) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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