gossip

package
v0.10.9 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2022 License: Apache-2.0 Imports: 21 Imported by: 1

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 RegisterPrimitiveServer 

func RegisterPrimitiveServer(server *grpc.Server, client *Client, env env.DriverEnv)

Types

type Client 

type Client struct {
	Cluster cluster.Cluster
	// contains filtered or unexported fields
}

Client is a client for communicating with the storage layer

func NewClient 

func NewClient(cluster cluster.Cluster) *Client

NewClient creates a new proxy client

func (*Client) Close 

func (c *Client) Close() error

type EpochClock added in v0.6.13 

type EpochClock struct {
	Election *EpochClockElection `protobuf:"bytes,1,opt,name=election,proto3" json:"election,omitempty"`
}

func (*EpochClock) Descriptor added in v0.6.13 

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

func (*EpochClock) GetElection added in v0.6.13 

func (m *EpochClock) GetElection() *EpochClockElection

func (*EpochClock) Marshal added in v0.6.13 

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

func (*EpochClock) MarshalTo added in v0.6.13 

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

func (*EpochClock) MarshalToSizedBuffer added in v0.6.13 

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

func (*EpochClock) ProtoMessage added in v0.6.13 

func (*EpochClock) ProtoMessage()

func (*EpochClock) Reset added in v0.6.13 

func (m *EpochClock) Reset()

func (*EpochClock) Size added in v0.6.13 

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

func (*EpochClock) String added in v0.6.13 

func (m *EpochClock) String() string

func (*EpochClock) Unmarshal added in v0.6.13 

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

func (*EpochClock) XXX_DiscardUnknown added in v0.6.13 

func (m *EpochClock) XXX_DiscardUnknown()

func (*EpochClock) XXX_Marshal added in v0.6.13 

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

func (*EpochClock) XXX_Merge added in v0.6.13 

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

func (*EpochClock) XXX_Size added in v0.6.13 

func (m *EpochClock) XXX_Size() int

func (*EpochClock) XXX_Unmarshal added in v0.6.13 

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

type EpochClockElection added in v0.6.13 

type EpochClockElection struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*EpochClockElection) Descriptor added in v0.6.13 

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

func (*EpochClockElection) GetName added in v0.6.13 

func (m *EpochClockElection) GetName() string

func (*EpochClockElection) Marshal added in v0.6.13 

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

func (*EpochClockElection) MarshalTo added in v0.6.13 

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

func (*EpochClockElection) MarshalToSizedBuffer added in v0.6.13 

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

func (*EpochClockElection) ProtoMessage added in v0.6.13 

func (*EpochClockElection) ProtoMessage()

func (*EpochClockElection) Reset added in v0.6.13 

func (m *EpochClockElection) Reset()

func (*EpochClockElection) Size added in v0.6.13 

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

func (*EpochClockElection) String added in v0.6.13 

func (m *EpochClockElection) String() string

func (*EpochClockElection) Unmarshal added in v0.6.13 

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

func (*EpochClockElection) XXX_DiscardUnknown added in v0.6.13 

func (m *EpochClockElection) XXX_DiscardUnknown()

func (*EpochClockElection) XXX_Marshal added in v0.6.13 

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

func (*EpochClockElection) XXX_Merge added in v0.6.13 

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

func (*EpochClockElection) XXX_Size added in v0.6.13 

func (m *EpochClockElection) XXX_Size() int

func (*EpochClockElection) XXX_Unmarshal added in v0.6.13 

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

type GossipClock added in v0.6.13 

type GossipClock struct {
	// Types that are valid to be assigned to Clock:
	//	*GossipClock_Logical
	//	*GossipClock_Physical
	//	*GossipClock_Epoch
	Clock isGossipClock_Clock `protobuf_oneof:"clock"`
}

func (*GossipClock) Descriptor added in v0.6.13 

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

func (*GossipClock) GetClock added in v0.6.13 

func (m *GossipClock) GetClock() isGossipClock_Clock

func (*GossipClock) GetEpoch added in v0.6.13 

func (m *GossipClock) GetEpoch() *EpochClock

func (*GossipClock) GetLogical added in v0.6.13 

func (m *GossipClock) GetLogical() *LogicalClock

func (*GossipClock) GetPhysical added in v0.6.13 

func (m *GossipClock) GetPhysical() *PhysicalClock

func (*GossipClock) Marshal added in v0.6.13 

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

func (*GossipClock) MarshalTo added in v0.6.13 

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

func (*GossipClock) MarshalToSizedBuffer added in v0.6.13 

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

func (*GossipClock) ProtoMessage added in v0.6.13 

func (*GossipClock) ProtoMessage()

func (*GossipClock) Reset added in v0.6.13 

func (m *GossipClock) Reset()

func (*GossipClock) Size added in v0.6.13 

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

func (*GossipClock) String added in v0.6.13 

func (m *GossipClock) String() string

func (*GossipClock) Unmarshal added in v0.6.13 

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

func (*GossipClock) XXX_DiscardUnknown added in v0.6.13 

func (m *GossipClock) XXX_DiscardUnknown()

func (*GossipClock) XXX_Marshal added in v0.6.13 

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

func (*GossipClock) XXX_Merge added in v0.6.13 

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

func (*GossipClock) XXX_OneofWrappers added in v0.6.13 

func (*GossipClock) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*GossipClock) XXX_Size added in v0.6.13 

func (m *GossipClock) XXX_Size() int

func (*GossipClock) XXX_Unmarshal added in v0.6.13 

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

type GossipClock_Epoch added in v0.6.13 

type GossipClock_Epoch struct {
	Epoch *EpochClock `protobuf:"bytes,3,opt,name=epoch,proto3,oneof" json:"epoch,omitempty"`
}

func (*GossipClock_Epoch) MarshalTo added in v0.6.13 

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

func (*GossipClock_Epoch) MarshalToSizedBuffer added in v0.6.13 

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

func (*GossipClock_Epoch) Size added in v0.6.13 

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

type GossipClock_Logical added in v0.6.13 

type GossipClock_Logical struct {
	Logical *LogicalClock `protobuf:"bytes,1,opt,name=logical,proto3,oneof" json:"logical,omitempty"`
}

func (*GossipClock_Logical) MarshalTo added in v0.6.13 

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

func (*GossipClock_Logical) MarshalToSizedBuffer added in v0.6.13 

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

func (*GossipClock_Logical) Size added in v0.6.13 

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

type GossipClock_Physical added in v0.6.13 

type GossipClock_Physical struct {
	Physical *PhysicalClock `protobuf:"bytes,2,opt,name=physical,proto3,oneof" json:"physical,omitempty"`
}

func (*GossipClock_Physical) MarshalTo added in v0.6.13 

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

func (*GossipClock_Physical) MarshalToSizedBuffer added in v0.6.13 

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

func (*GossipClock_Physical) Size added in v0.6.13 

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

type GossipConfig added in v0.6.13 

type GossipConfig struct {
	Clock             *GossipClock `protobuf:"bytes,1,opt,name=clock,proto3" json:"clock,omitempty"`
	ReplicationFactor uint32       `protobuf:"varint,2,opt,name=replication_factor,json=replicationFactor,proto3" json:"replication_factor,omitempty"`
}

func (*GossipConfig) Descriptor added in v0.6.13 

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

func (*GossipConfig) GetClock added in v0.6.13 

func (m *GossipConfig) GetClock() *GossipClock

func (*GossipConfig) GetReplicationFactor added in v0.6.13 

func (m *GossipConfig) GetReplicationFactor() uint32

func (*GossipConfig) Marshal added in v0.6.13 

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

func (*GossipConfig) MarshalTo added in v0.6.13 

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

func (*GossipConfig) MarshalToSizedBuffer added in v0.6.13 

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

func (*GossipConfig) ProtoMessage added in v0.6.13 

func (*GossipConfig) ProtoMessage()

func (*GossipConfig) Reset added in v0.6.13 

func (m *GossipConfig) Reset()

func (*GossipConfig) Size added in v0.6.13 

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

func (*GossipConfig) String added in v0.6.13 

func (m *GossipConfig) String() string

func (*GossipConfig) Unmarshal added in v0.6.13 

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

func (*GossipConfig) XXX_DiscardUnknown added in v0.6.13 

func (m *GossipConfig) XXX_DiscardUnknown()

func (*GossipConfig) XXX_Marshal added in v0.6.13 

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

func (*GossipConfig) XXX_Merge added in v0.6.13 

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

func (*GossipConfig) XXX_Size added in v0.6.13 

func (m *GossipConfig) XXX_Size() int

func (*GossipConfig) XXX_Unmarshal added in v0.6.13 

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

type LogicalClock added in v0.6.13 

type LogicalClock struct {
}

func (*LogicalClock) Descriptor added in v0.6.13 

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

func (*LogicalClock) Marshal added in v0.6.13 

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

func (*LogicalClock) MarshalTo added in v0.6.13 

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

func (*LogicalClock) MarshalToSizedBuffer added in v0.6.13 

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

func (*LogicalClock) ProtoMessage added in v0.6.13 

func (*LogicalClock) ProtoMessage()

func (*LogicalClock) Reset added in v0.6.13 

func (m *LogicalClock) Reset()

func (*LogicalClock) Size added in v0.6.13 

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

func (*LogicalClock) String added in v0.6.13 

func (m *LogicalClock) String() string

func (*LogicalClock) Unmarshal added in v0.6.13 

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

func (*LogicalClock) XXX_DiscardUnknown added in v0.6.13 

func (m *LogicalClock) XXX_DiscardUnknown()

func (*LogicalClock) XXX_Marshal added in v0.6.13 

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

func (*LogicalClock) XXX_Merge added in v0.6.13 

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

func (*LogicalClock) XXX_Size added in v0.6.13 

func (m *LogicalClock) XXX_Size() int

func (*LogicalClock) XXX_Unmarshal added in v0.6.13 

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

type Partition 

type Partition struct {
	*PartitionClient
	// contains filtered or unexported fields
}

func (*Partition) AddRequestHeaders 

func (p *Partition) AddRequestHeaders(ctx context.Context, headers *primitive.RequestHeaders) context.Context

func (*Partition) AddResponseHeaders 

func (p *Partition) AddResponseHeaders(headers *primitive.ResponseHeaders)

type PartitionClient added in v0.6.13 

type PartitionClient struct {
	cluster.Partition

	ID PartitionID
	// contains filtered or unexported fields
}

partitionClient is a proxy partition client

func (*PartitionClient) Close added in v0.6.13 

func (p *PartitionClient) Close() error

Close closes the connections

func (*PartitionClient) Connect added in v0.6.13 

func (p *PartitionClient) Connect() (*grpc.ClientConn, error)

Connect gets the connection to the partition

type PartitionID 

type PartitionID int

PartitionID is a partition identifier

type PhysicalClock added in v0.6.13 

type PhysicalClock struct {
}

func (*PhysicalClock) Descriptor added in v0.6.13 

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

func (*PhysicalClock) Marshal added in v0.6.13 

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

func (*PhysicalClock) MarshalTo added in v0.6.13 

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

func (*PhysicalClock) MarshalToSizedBuffer added in v0.6.13 

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

func (*PhysicalClock) ProtoMessage added in v0.6.13 

func (*PhysicalClock) ProtoMessage()

func (*PhysicalClock) Reset added in v0.6.13 

func (m *PhysicalClock) Reset()

func (*PhysicalClock) Size added in v0.6.13 

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

func (*PhysicalClock) String added in v0.6.13 

func (m *PhysicalClock) String() string

func (*PhysicalClock) Unmarshal added in v0.6.13 

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

func (*PhysicalClock) XXX_DiscardUnknown added in v0.6.13 

func (m *PhysicalClock) XXX_DiscardUnknown()

func (*PhysicalClock) XXX_Marshal added in v0.6.13 

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

func (*PhysicalClock) XXX_Merge added in v0.6.13 

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

func (*PhysicalClock) XXX_Size added in v0.6.13 

func (m *PhysicalClock) XXX_Size() int

func (*PhysicalClock) XXX_Unmarshal added in v0.6.13 

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

type PrimitiveServer 

type PrimitiveServer struct {
	*Server
	// contains filtered or unexported fields
}

func (*PrimitiveServer) Close 

func (s *PrimitiveServer) Close(ctx context.Context, request *primitiveapi.CloseRequest) (*primitiveapi.CloseResponse, error)

func (*PrimitiveServer) Create 

func (s *PrimitiveServer) Create(ctx context.Context, request *primitiveapi.CreateRequest) (*primitiveapi.CreateResponse, error)

func (*PrimitiveServer) Delete 

func (s *PrimitiveServer) Delete(ctx context.Context, request *primitiveapi.DeleteRequest) (*primitiveapi.DeleteResponse, error)

type Protocol 

type Protocol struct {
	*server.Server
	Client *Client
	Env    env.DriverEnv
	// contains filtered or unexported fields
}

Protocol is a state machine protocol

func NewProtocol 

func NewProtocol(cluster cluster.Cluster, env env.DriverEnv) *Protocol

NewProtocol creates a new state machine protocol

func (*Protocol) Configure 

func (n *Protocol) Configure(config protocolapi.ProtocolConfig) error

Configure configures the protocol

func (*Protocol) Name 

func (n *Protocol) Name() string

Name returns the protocol name

func (*Protocol) Primitives 

func (n *Protocol) Primitives() *primitive.PrimitiveTypeRegistry

Primitives returns the protocol primitives

func (*Protocol) Start 

func (n *Protocol) Start() error

Start starts the node

func (*Protocol) Stop 

func (n *Protocol) Stop() error

Stop stops the node

type Server added in v0.6.13 

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

func NewServer added in v0.6.13 

func NewServer(client *Client, config GossipConfig) *Server

func (*Server) AddResponseHeaders added in v0.6.13 

func (s *Server) AddResponseHeaders(headers *primitive.ResponseHeaders)

func (*Server) Partition added in v0.6.13 

func (s *Server) Partition(partitionID PartitionID) *Partition

func (*Server) PartitionBy added in v0.6.13 

func (s *Server) PartitionBy(partitionKey []byte) *Partition

func (*Server) Partitions added in v0.6.13 

func (s *Server) Partitions() []*Partition

Source Files

View all Source files

Directories

Path Synopsis
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.
Code generated by atomix-go-framework.
 Code generated by atomix-go-framework.

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.