protocol

package

Go to main page

Versions in this module

v0

v0.99.0

Apr 22, 2024

Changes in this version

+ var MaxHotStandbys uint32 = math.MaxUint32

type ListResponse_Shard

+ CreateRevision int64

type ShardClient

+ Unassign func(ctx context.Context, in *UnassignRequest, opts ...grpc.CallOption) (*UnassignResponse, error)

type ShardServer

+ Unassign func(context.Context, *UnassignRequest) (*UnassignResponse, error)

type ShardSpec

+ ReadChannelSize uint32

+ RingBufferSize uint32

+ func (this *ShardSpec) Equal(that interface{}) bool

type ShardSpec_Source

+ func (this *ShardSpec_Source) Equal(that interface{}) bool

type Status

+ const Status_SHARD_STOPPED

+ type UnassignRequest struct

+ DryRun bool

+ OnlyFailed bool

+ Shards []ShardID

+ func (*UnassignRequest) Descriptor() ([]byte, []int)

+ func (*UnassignRequest) ProtoMessage()

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

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

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

+ func (m *UnassignRequest) ProtoSize() (n int)

+ func (m *UnassignRequest) Reset()

+ func (m *UnassignRequest) String() string

+ func (m *UnassignRequest) Unmarshal(dAtA []byte) error

+ func (m *UnassignRequest) Validate() error

+ func (m *UnassignRequest) XXX_DiscardUnknown()

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

+ func (m *UnassignRequest) XXX_Merge(src proto.Message)

+ func (m *UnassignRequest) XXX_Size() int

+ func (m *UnassignRequest) XXX_Unmarshal(b []byte) error

+ type UnassignResponse struct

+ Shards []ShardID

+ Status Status

+ func (*UnassignResponse) Descriptor() ([]byte, []int)

+ func (*UnassignResponse) ProtoMessage()

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

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

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

+ func (m *UnassignResponse) ProtoSize() (n int)

+ func (m *UnassignResponse) Reset()

+ func (m *UnassignResponse) String() string

+ func (m *UnassignResponse) Unmarshal(dAtA []byte) error

+ func (m *UnassignResponse) Validate() error

+ func (m *UnassignResponse) XXX_DiscardUnknown()

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

+ func (m *UnassignResponse) XXX_Merge(src proto.Message)

+ func (m *UnassignResponse) XXX_Size() int

+ func (m *UnassignResponse) XXX_Unmarshal(b []byte) error

type UnimplementedShardServer

+ func (*UnimplementedShardServer) Unassign(ctx context.Context, req *UnassignRequest) (*UnassignResponse, error)

v0.89.0

Sep 2, 2021

Changes in this version

type ApplyRequest

+ Extension []byte

type ApplyResponse

+ Extension []byte

+ type Checkpoint_Source_ProducerEntry struct

+ Id []byte

+ State Checkpoint_ProducerState

+ func (*Checkpoint_Source_ProducerEntry) Descriptor() ([]byte, []int)

+ func (*Checkpoint_Source_ProducerEntry) ProtoMessage()

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

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

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

+ func (m *Checkpoint_Source_ProducerEntry) ProtoSize() (n int)

+ func (m *Checkpoint_Source_ProducerEntry) Reset()

+ func (m *Checkpoint_Source_ProducerEntry) String() string

+ func (m *Checkpoint_Source_ProducerEntry) Unmarshal(dAtA []byte) error

+ func (m *Checkpoint_Source_ProducerEntry) XXX_DiscardUnknown()

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

+ func (m *Checkpoint_Source_ProducerEntry) XXX_Merge(src proto.Message)

+ func (m *Checkpoint_Source_ProducerEntry) XXX_Size() int

+ func (m *Checkpoint_Source_ProducerEntry) XXX_Unmarshal(b []byte) error

type GetHintsRequest

+ Extension []byte

type GetHintsResponse

+ Extension []byte

type ListRequest

+ Extension []byte

type ListResponse

+ Extension []byte

type StatRequest

+ Extension []byte

type StatResponse

+ Extension []byte

v0.88.0

Jul 16, 2020

v0.87.3

Jun 10, 2020

v0.87.2

Jun 1, 2020

v0.87.1

May 26, 2020

v0.86.1

Apr 24, 2020

Changes in this version

+ var ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group")

type ApplyRequest

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

type ApplyRequest_Change

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

type ApplyResponse

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

type Checkpoint

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

type Checkpoint_ProducerState

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

type Checkpoint_Source

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

type ConsumerSpec

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

type GetHintsRequest

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

type GetHintsResponse

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

type GetHintsResponse_ResponseHints

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

type ListRequest

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

type ListResponse

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

type ListResponse_Shard

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

type ReplicaStatus

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

type ShardSpec

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

type ShardSpec_Source

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

type StatRequest

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

type StatResponse

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

+ type UnimplementedShardServer struct

+ func (*UnimplementedShardServer) Apply(ctx context.Context, req *ApplyRequest) (*ApplyResponse, error)

+ func (*UnimplementedShardServer) GetHints(ctx context.Context, req *GetHintsRequest) (*GetHintsResponse, error)

+ func (*UnimplementedShardServer) List(ctx context.Context, req *ListRequest) (*ListResponse, error)

+ func (*UnimplementedShardServer) Stat(ctx context.Context, req *StatRequest) (*StatResponse, error)

v0.85.2

Dec 4, 2019

v0.85.1

Dec 3, 2019

Changes in this version

type ShardSpec

+ DisableWaitForAck bool

v0.84.2

Nov 6, 2019

v0.84.1

Oct 30, 2019

v0.83.2

Oct 4, 2019

v0.83.1

Oct 4, 2019

Changes in this version

+ func FlattenProducerStates(cp Checkpoint) []message.ProducerState

+ func FlattenReadThrough(cp Checkpoint) pb.Offsets

+ type BuildCheckpointArgs struct

+ AckIntents []message.AckIntent

+ ProducerStates []message.ProducerState

+ ReadThrough pb.Offsets

+ type Checkpoint struct

+ AckIntents map[go_gazette_dev_core_broker_protocol.Journal][]byte

+ Sources map[go_gazette_dev_core_broker_protocol.Journal]Checkpoint_Source

+ func BuildCheckpoint(args BuildCheckpointArgs) Checkpoint

+ func (*Checkpoint) Descriptor() ([]byte, []int)

+ func (*Checkpoint) ProtoMessage()

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

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

+ func (m *Checkpoint) ProtoSize() (n int)

+ func (m *Checkpoint) Reset()

+ func (m *Checkpoint) String() string

+ func (m *Checkpoint) Unmarshal(dAtA []byte) error

+ func (m *Checkpoint) XXX_DiscardUnknown()

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

+ func (m *Checkpoint) XXX_Merge(src proto.Message)

+ func (m *Checkpoint) XXX_Size() int

+ func (m *Checkpoint) XXX_Unmarshal(b []byte) error

+ type Checkpoint_ProducerState struct

+ Begin go_gazette_dev_core_broker_protocol.Offset

+ LastAck go_gazette_dev_core_message.Clock

+ func (*Checkpoint_ProducerState) Descriptor() ([]byte, []int)

+ func (*Checkpoint_ProducerState) ProtoMessage()

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

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

+ func (m *Checkpoint_ProducerState) ProtoSize() (n int)

+ func (m *Checkpoint_ProducerState) Reset()

+ func (m *Checkpoint_ProducerState) String() string

+ func (m *Checkpoint_ProducerState) Unmarshal(dAtA []byte) error

+ func (m *Checkpoint_ProducerState) XXX_DiscardUnknown()

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

+ func (m *Checkpoint_ProducerState) XXX_Merge(src proto.Message)

+ func (m *Checkpoint_ProducerState) XXX_Size() int

+ func (m *Checkpoint_ProducerState) XXX_Unmarshal(b []byte) error

+ type Checkpoint_Source struct

+ Producers map[string]Checkpoint_ProducerState

+ ReadThrough go_gazette_dev_core_broker_protocol.Offset

+ func (*Checkpoint_Source) Descriptor() ([]byte, []int)

+ func (*Checkpoint_Source) ProtoMessage()

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

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

+ func (m *Checkpoint_Source) ProtoSize() (n int)

+ func (m *Checkpoint_Source) Reset()

+ func (m *Checkpoint_Source) String() string

+ func (m *Checkpoint_Source) Unmarshal(dAtA []byte) error

+ func (m *Checkpoint_Source) XXX_DiscardUnknown()

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

+ func (m *Checkpoint_Source) XXX_Merge(src proto.Message)

+ func (m *Checkpoint_Source) XXX_Size() int

+ func (m *Checkpoint_Source) XXX_Unmarshal(b []byte) error

type ReplicaStatus_Code

+ const ReplicaStatus_STANDBY

type StatRequest

+ ReadThrough map[go_gazette_dev_core_broker_protocol.Journal]go_gazette_dev_core_broker_protocol.Offset

type StatResponse

+ PublishAt map[go_gazette_dev_core_broker_protocol.Journal]go_gazette_dev_core_broker_protocol.Offset

+ ReadThrough map[go_gazette_dev_core_broker_protocol.Journal]go_gazette_dev_core_broker_protocol.Offset

v0.82.2

Oct 4, 2019

v0.82.1

Sep 10, 2019

Changes in this version

+ var ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ReplicaStatus_Code_name = map[int32]string

+ var ReplicaStatus_Code_value = map[string]int32

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ func ExtractShardSpecMetaLabels(spec *ShardSpec, out pb.LabelSet) pb.LabelSet

+ func RegisterShardServer(s *grpc.Server, srv ShardServer)

+ type ApplyRequest struct

+ Changes []ApplyRequest_Change

+ func (*ApplyRequest) Descriptor() ([]byte, []int)

+ func (*ApplyRequest) ProtoMessage()

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

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

+ func (m *ApplyRequest) ProtoSize() (n int)

+ func (m *ApplyRequest) Reset()

+ func (m *ApplyRequest) String() string

+ func (m *ApplyRequest) Unmarshal(dAtA []byte) error

+ func (m *ApplyRequest) Validate() error

+ func (m *ApplyRequest) XXX_DiscardUnknown()

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

+ func (m *ApplyRequest) XXX_Merge(src proto.Message)

+ func (m *ApplyRequest) XXX_Size() int

+ func (m *ApplyRequest) XXX_Unmarshal(b []byte) error

+ type ApplyRequest_Change struct

+ Delete ShardID

+ ExpectModRevision int64

+ Upsert *ShardSpec

+ func (*ApplyRequest_Change) Descriptor() ([]byte, []int)

+ func (*ApplyRequest_Change) ProtoMessage()

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

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

+ func (m *ApplyRequest_Change) ProtoSize() (n int)

+ func (m *ApplyRequest_Change) Reset()

+ func (m *ApplyRequest_Change) String() string

+ func (m *ApplyRequest_Change) Unmarshal(dAtA []byte) error

+ func (m *ApplyRequest_Change) Validate() error

+ func (m *ApplyRequest_Change) XXX_DiscardUnknown()

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

+ func (m *ApplyRequest_Change) XXX_Merge(src proto.Message)

+ func (m *ApplyRequest_Change) XXX_Size() int

+ func (m *ApplyRequest_Change) XXX_Unmarshal(b []byte) error

+ type ApplyResponse struct

+ Header protocol.Header

+ Status Status

+ func (*ApplyResponse) Descriptor() ([]byte, []int)

+ func (*ApplyResponse) ProtoMessage()

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

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

+ func (m *ApplyResponse) ProtoSize() (n int)

+ func (m *ApplyResponse) Reset()

+ func (m *ApplyResponse) String() string

+ func (m *ApplyResponse) Unmarshal(dAtA []byte) error

+ func (m *ApplyResponse) Validate() error

+ func (m *ApplyResponse) XXX_DiscardUnknown()

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

+ func (m *ApplyResponse) XXX_Merge(src proto.Message)

+ func (m *ApplyResponse) XXX_Size() int

+ func (m *ApplyResponse) XXX_Unmarshal(b []byte) error

+ type ConsumerSpec struct

+ ShardLimit uint32

+ func (*ConsumerSpec) Descriptor() ([]byte, []int)

+ func (*ConsumerSpec) ProtoMessage()

+ func (m *ConsumerSpec) ItemLimit() int

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

+ func (m *ConsumerSpec) MarshalString() string

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

+ func (m *ConsumerSpec) ProtoSize() (n int)

+ func (m *ConsumerSpec) Reset()

+ func (m *ConsumerSpec) String() string

+ func (m *ConsumerSpec) Unmarshal(dAtA []byte) error

+ func (m *ConsumerSpec) Validate() error

+ func (m *ConsumerSpec) XXX_DiscardUnknown()

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

+ func (m *ConsumerSpec) XXX_Merge(src proto.Message)

+ func (m *ConsumerSpec) XXX_Size() int

+ func (m *ConsumerSpec) XXX_Unmarshal(b []byte) error

+ func (m *ConsumerSpec) ZeroLimit()

+ type GetHintsRequest struct

+ Shard ShardID

+ func (*GetHintsRequest) Descriptor() ([]byte, []int)

+ func (*GetHintsRequest) ProtoMessage()

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

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

+ func (m *GetHintsRequest) ProtoSize() (n int)

+ func (m *GetHintsRequest) Reset()

+ func (m *GetHintsRequest) String() string

+ func (m *GetHintsRequest) Unmarshal(dAtA []byte) error

+ func (m *GetHintsRequest) Validate() error

+ func (m *GetHintsRequest) XXX_DiscardUnknown()

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

+ func (m *GetHintsRequest) XXX_Merge(src proto.Message)

+ func (m *GetHintsRequest) XXX_Size() int

+ func (m *GetHintsRequest) XXX_Unmarshal(b []byte) error

+ type GetHintsResponse struct

+ BackupHints []GetHintsResponse_ResponseHints

+ Header protocol.Header

+ PrimaryHints GetHintsResponse_ResponseHints

+ Status Status

+ func (*GetHintsResponse) Descriptor() ([]byte, []int)

+ func (*GetHintsResponse) ProtoMessage()

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

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

+ func (m *GetHintsResponse) ProtoSize() (n int)

+ func (m *GetHintsResponse) Reset()

+ func (m *GetHintsResponse) String() string

+ func (m *GetHintsResponse) Unmarshal(dAtA []byte) error

+ func (m *GetHintsResponse) Validate() error

+ func (m *GetHintsResponse) XXX_DiscardUnknown()

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

+ func (m *GetHintsResponse) XXX_Merge(src proto.Message)

+ func (m *GetHintsResponse) XXX_Size() int

+ func (m *GetHintsResponse) XXX_Unmarshal(b []byte) error

+ type GetHintsResponse_ResponseHints struct

+ Hints *recoverylog.FSMHints

+ func (*GetHintsResponse_ResponseHints) Descriptor() ([]byte, []int)

+ func (*GetHintsResponse_ResponseHints) ProtoMessage()

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

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

+ func (m *GetHintsResponse_ResponseHints) ProtoSize() (n int)

+ func (m *GetHintsResponse_ResponseHints) Reset()

+ func (m *GetHintsResponse_ResponseHints) String() string

+ func (m *GetHintsResponse_ResponseHints) Unmarshal(dAtA []byte) error

+ func (m *GetHintsResponse_ResponseHints) XXX_DiscardUnknown()

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

+ func (m *GetHintsResponse_ResponseHints) XXX_Merge(src proto.Message)

+ func (m *GetHintsResponse_ResponseHints) XXX_Size() int

+ func (m *GetHintsResponse_ResponseHints) XXX_Unmarshal(b []byte) error

+ func (m GetHintsResponse_ResponseHints) Validate() error

+ type ListRequest struct

+ Selector protocol.LabelSelector

+ func (*ListRequest) Descriptor() ([]byte, []int)

+ func (*ListRequest) ProtoMessage()

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

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

+ func (m *ListRequest) ProtoSize() (n int)

+ func (m *ListRequest) Reset()

+ func (m *ListRequest) String() string

+ func (m *ListRequest) Unmarshal(dAtA []byte) error

+ func (m *ListRequest) Validate() error

+ func (m *ListRequest) XXX_DiscardUnknown()

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

+ func (m *ListRequest) XXX_Merge(src proto.Message)

+ func (m *ListRequest) XXX_Size() int

+ func (m *ListRequest) XXX_Unmarshal(b []byte) error

+ type ListResponse struct

+ Header protocol.Header

+ Shards []ListResponse_Shard

+ Status Status

+ func (*ListResponse) Descriptor() ([]byte, []int)

+ func (*ListResponse) ProtoMessage()

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

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

+ func (m *ListResponse) ProtoSize() (n int)

+ func (m *ListResponse) Reset()

+ func (m *ListResponse) String() string

+ func (m *ListResponse) Unmarshal(dAtA []byte) error

+ func (m *ListResponse) Validate() error

+ func (m *ListResponse) XXX_DiscardUnknown()

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

+ func (m *ListResponse) XXX_Merge(src proto.Message)

+ func (m *ListResponse) XXX_Size() int

+ func (m *ListResponse) XXX_Unmarshal(b []byte) error

+ type ListResponse_Shard struct

+ ModRevision int64

+ Route protocol.Route

+ Spec ShardSpec

+ Status []ReplicaStatus

+ func (*ListResponse_Shard) Descriptor() ([]byte, []int)

+ func (*ListResponse_Shard) ProtoMessage()

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

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

+ func (m *ListResponse_Shard) ProtoSize() (n int)

+ func (m *ListResponse_Shard) Reset()

+ func (m *ListResponse_Shard) String() string

+ func (m *ListResponse_Shard) Unmarshal(dAtA []byte) error

+ func (m *ListResponse_Shard) Validate() error

+ func (m *ListResponse_Shard) XXX_DiscardUnknown()

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

+ func (m *ListResponse_Shard) XXX_Merge(src proto.Message)

+ func (m *ListResponse_Shard) XXX_Size() int

+ func (m *ListResponse_Shard) XXX_Unmarshal(b []byte) error

+ type ReplicaStatus struct

+ Code ReplicaStatus_Code

+ Errors []string

+ func (*ReplicaStatus) Descriptor() ([]byte, []int)

+ func (*ReplicaStatus) ProtoMessage()

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

+ func (m *ReplicaStatus) MarshalString() string

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

+ func (m *ReplicaStatus) ProtoSize() (n int)

+ func (m *ReplicaStatus) Reduce(other *ReplicaStatus)

+ func (m *ReplicaStatus) Reset()

+ func (m *ReplicaStatus) String() string

+ func (m *ReplicaStatus) Unmarshal(dAtA []byte) error

+ func (m *ReplicaStatus) Validate() error

+ func (m *ReplicaStatus) XXX_DiscardUnknown()

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

+ func (m *ReplicaStatus) XXX_Merge(src proto.Message)

+ func (m *ReplicaStatus) XXX_Size() int

+ func (m *ReplicaStatus) XXX_Unmarshal(b []byte) error

+ type ReplicaStatus_Code int32

+ const ReplicaStatus_BACKFILL

+ const ReplicaStatus_FAILED

+ const ReplicaStatus_IDLE

+ const ReplicaStatus_PRIMARY

+ const ReplicaStatus_TAILING

+ func (ReplicaStatus_Code) EnumDescriptor() ([]byte, []int)

+ func (x ReplicaStatus_Code) String() string

+ func (x ReplicaStatus_Code) Validate() error

+ type RoutedShardClient interface

+ func NewRoutedShardClient(sc ShardClient, dr pb.DispatchRouter) RoutedShardClient

+ type ShardClient interface

+ Apply func(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)

+ GetHints func(ctx context.Context, in *GetHintsRequest, opts ...grpc.CallOption) (*GetHintsResponse, error)

+ List func(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)

+ Stat func(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)

+ func NewShardClient(cc *grpc.ClientConn) ShardClient

+ type ShardID string

+ func (id ShardID) String() string

+ func (id ShardID) Validate() error

+ type ShardServer interface

+ Apply func(context.Context, *ApplyRequest) (*ApplyResponse, error)

+ GetHints func(context.Context, *GetHintsRequest) (*GetHintsResponse, error)

+ List func(context.Context, *ListRequest) (*ListResponse, error)

+ Stat func(context.Context, *StatRequest) (*StatResponse, error)

+ type ShardSpec struct

+ Disable bool

+ HintBackups int32

+ HintPrefix string

+ HotStandbys uint32

+ Id ShardID

+ MaxTxnDuration time.Duration

+ MinTxnDuration time.Duration

+ RecoveryLogPrefix string

+ Sources []ShardSpec_Source

+ func IntersectShardSpecs(a, b ShardSpec) ShardSpec

+ func SubtractShardSpecs(a, b ShardSpec) ShardSpec

+ func UnionShardSpecs(a, b ShardSpec) ShardSpec

+ func (*ShardSpec) Descriptor() ([]byte, []int)

+ func (*ShardSpec) ProtoMessage()

+ func (m *ShardSpec) DesiredReplication() int

+ func (m *ShardSpec) HintBackupKeys() []string

+ func (m *ShardSpec) HintPrimaryKey() string

+ func (m *ShardSpec) IsConsistent(assignment keyspace.KeyValue, all keyspace.KeyValues) bool

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

+ func (m *ShardSpec) MarshalString() string

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

+ func (m *ShardSpec) ProtoSize() (n int)

+ func (m *ShardSpec) RecoveryLog() pb.Journal

+ func (m *ShardSpec) Reset()

+ func (m *ShardSpec) String() string

+ func (m *ShardSpec) Unmarshal(dAtA []byte) error

+ func (m *ShardSpec) Validate() error

+ func (m *ShardSpec) XXX_DiscardUnknown()

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

+ func (m *ShardSpec) XXX_Merge(src proto.Message)

+ func (m *ShardSpec) XXX_Size() int

+ func (m *ShardSpec) XXX_Unmarshal(b []byte) error

+ type ShardSpec_Source struct

+ Journal go_gazette_dev_core_broker_protocol.Journal

+ MinOffset int64

+ func (*ShardSpec_Source) Descriptor() ([]byte, []int)

+ func (*ShardSpec_Source) ProtoMessage()

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

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

+ func (m *ShardSpec_Source) ProtoSize() (n int)

+ func (m *ShardSpec_Source) Reset()

+ func (m *ShardSpec_Source) String() string

+ func (m *ShardSpec_Source) Unmarshal(dAtA []byte) error

+ func (m *ShardSpec_Source) Validate() error

+ func (m *ShardSpec_Source) XXX_DiscardUnknown()

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

+ func (m *ShardSpec_Source) XXX_Merge(src proto.Message)

+ func (m *ShardSpec_Source) XXX_Size() int

+ func (m *ShardSpec_Source) XXX_Unmarshal(b []byte) error

+ type StatRequest struct

+ Header *protocol.Header

+ Shard ShardID

+ func (*StatRequest) Descriptor() ([]byte, []int)

+ func (*StatRequest) ProtoMessage()

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

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

+ func (m *StatRequest) ProtoSize() (n int)

+ func (m *StatRequest) Reset()

+ func (m *StatRequest) String() string

+ func (m *StatRequest) Unmarshal(dAtA []byte) error

+ func (m *StatRequest) Validate() error

+ func (m *StatRequest) XXX_DiscardUnknown()

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

+ func (m *StatRequest) XXX_Merge(src proto.Message)

+ func (m *StatRequest) XXX_Size() int

+ func (m *StatRequest) XXX_Unmarshal(b []byte) error

+ type StatResponse struct

+ Header protocol.Header

+ Offsets map[go_gazette_dev_core_broker_protocol.Journal]int64

+ Status Status

+ func (*StatResponse) Descriptor() ([]byte, []int)

+ func (*StatResponse) ProtoMessage()

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

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

+ func (m *StatResponse) ProtoSize() (n int)

+ func (m *StatResponse) Reset()

+ func (m *StatResponse) String() string

+ func (m *StatResponse) Unmarshal(dAtA []byte) error

+ func (m *StatResponse) Validate() error

+ func (m *StatResponse) XXX_DiscardUnknown()

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

+ func (m *StatResponse) XXX_Merge(src proto.Message)

+ func (m *StatResponse) XXX_Size() int

+ func (m *StatResponse) XXX_Unmarshal(b []byte) error

+ type Status int32

+ const Status_ETCD_TRANSACTION_FAILED

+ const Status_NOT_SHARD_PRIMARY

+ const Status_NO_SHARD_PRIMARY

+ const Status_OK

+ const Status_SHARD_NOT_FOUND

+ func (Status) EnumDescriptor() ([]byte, []int)

+ func (x Status) String() string

+ func (x Status) Validate() error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL