Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

protocol

package

Go to main page

Versions in this module

v1

v1.0.1

Sep 9, 2019

v0

v0.1.0

Jul 3, 2019

Changes in this version

+ const DispatcherGRPCBalancerName

+ var CompressionCodec_name = map[int32]string

+ var CompressionCodec_value = map[string]int32

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

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

+ var JournalSpec_Flag_name = map[int32]string

+ var JournalSpec_Flag_value = map[string]int32

+ var Status_name = map[int32]string

+ var Status_value = map[string]int32

+ func ExtendContext(err error, format string, args ...interface{}) error

+ func NewValidationError(format string, args ...interface{}) error

+ func RegisterGRPCDispatcher(localZone string)

+ func RegisterJournalServer(s *grpc.Server, srv JournalServer)

+ func ValidateSingleValueLabels(m LabelSet) error

+ func ValidateToken(n string, min, max int) error

+ func WithDispatchDefault(ctx context.Context) context.Context

+ func WithDispatchItemRoute(ctx context.Context, dr DispatchRouter, item string, requirePrimary bool) context.Context

+ func WithDispatchRoute(ctx context.Context, rt Route, id ProcessSpec_ID) context.Context

+ type AppendRequest struct

+ Content []byte

+ DoNotProxy bool

+ Header *Header

+ Journal Journal

+ Offset int64

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

+ func (*AppendRequest) ProtoMessage()

+ func (dst *AppendRequest) XXX_Merge(src proto.Message)

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

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

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

+ func (m *AppendRequest) Reset()

+ func (m *AppendRequest) String() string

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

+ func (m *AppendRequest) Validate() error

+ func (m *AppendRequest) XXX_DiscardUnknown()

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

+ func (m *AppendRequest) XXX_Size() int

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

+ type AppendResponse struct

+ Commit *Fragment

+ Header Header

+ Status Status

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

+ func (*AppendResponse) ProtoMessage()

+ func (dst *AppendResponse) XXX_Merge(src proto.Message)

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

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

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

+ func (m *AppendResponse) Reset()

+ func (m *AppendResponse) String() string

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

+ func (m *AppendResponse) Validate() error

+ func (m *AppendResponse) XXX_DiscardUnknown()

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

+ func (m *AppendResponse) XXX_Size() int

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

+ type ApplyRequest struct

+ Changes []ApplyRequest_Change

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

+ func (*ApplyRequest) ProtoMessage()

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

+ 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_Size() int

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

+ type ApplyRequest_Change struct

+ Delete Journal

+ ExpectModRevision int64

+ Upsert *JournalSpec

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

+ func (*ApplyRequest_Change) ProtoMessage()

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

+ 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_Size() int

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

+ type ApplyResponse struct

+ Header Header

+ Status Status

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

+ func (*ApplyResponse) ProtoMessage()

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

+ 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_Size() int

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

+ type BrokerSpec struct

+ JournalLimit uint32

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

+ func (*BrokerSpec) ProtoMessage()

+ func (dst *BrokerSpec) XXX_Merge(src proto.Message)

+ func (m *BrokerSpec) ItemLimit() int

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

+ func (m *BrokerSpec) MarshalString() string

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

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

+ func (m *BrokerSpec) Reset()

+ func (m *BrokerSpec) String() string

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

+ func (m *BrokerSpec) Validate() error

+ func (m *BrokerSpec) XXX_DiscardUnknown()

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

+ func (m *BrokerSpec) XXX_Size() int

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

+ func (m *BrokerSpec) ZeroLimit()

+ type CompressionCodec int32

+ const CompressionCodec_GZIP

+ const CompressionCodec_GZIP_OFFLOAD_DECOMPRESSION

+ const CompressionCodec_INVALID

+ const CompressionCodec_NONE

+ const CompressionCodec_SNAPPY

+ const CompressionCodec_ZSTANDARD

+ func CompressionCodecFromExtension(ext string) (CompressionCodec, error)

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

+ func (m *CompressionCodec) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (m CompressionCodec) MarshalYAML() (interface{}, error)

+ func (m CompressionCodec) ToExtension() string

+ func (m CompressionCodec) Validate() error

+ func (x CompressionCodec) String() string

+ type DispatchRouter interface

+ IsNoopRouter func() bool

+ Route func(ctx context.Context, item string) Route

+ UpdateRoute func(item string, route *Route)

+ type Endpoint string

+ func (ep Endpoint) URL() *url.URL

+ func (ep Endpoint) Validate() error

+ type Fragment struct

+ BackingStore FragmentStore

+ Begin int64

+ CompressionCodec CompressionCodec

+ End int64

+ Journal Journal

+ ModTime int64

+ Sum SHA1Sum

+ func ParseContentName(journal Journal, name string) (Fragment, error)

+ func ParseContentPath(p string) (Fragment, error)

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

+ func (*Fragment) ProtoMessage()

+ func (dst *Fragment) XXX_Merge(src proto.Message)

+ func (m *Fragment) ContentLength() int64

+ func (m *Fragment) ContentName() string

+ func (m *Fragment) ContentPath() string

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

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

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

+ func (m *Fragment) Reset()

+ func (m *Fragment) String() string

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

+ func (m *Fragment) Validate() error

+ func (m *Fragment) XXX_DiscardUnknown()

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

+ func (m *Fragment) XXX_Size() int

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

+ type FragmentStore string

+ func (fs FragmentStore) URL() *url.URL

+ func (fs FragmentStore) Validate() error

+ type FragmentsRequest struct

+ BeginModTime int64

+ DoNotProxy bool

+ EndModTime int64

+ Header *Header

+ Journal Journal

+ NextPageToken int64

+ PageLimit int32

+ SignatureTTL *time.Duration

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

+ func (*FragmentsRequest) ProtoMessage()

+ func (dst *FragmentsRequest) XXX_Merge(src proto.Message)

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

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

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

+ func (m *FragmentsRequest) Reset()

+ func (m *FragmentsRequest) String() string

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

+ func (m *FragmentsRequest) Validate() error

+ func (m *FragmentsRequest) XXX_DiscardUnknown()

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

+ func (m *FragmentsRequest) XXX_Size() int

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

+ type FragmentsResponse struct

+ Fragments []FragmentsResponse__Fragment

+ Header Header

+ NextPageToken int64

+ Status Status

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

+ func (*FragmentsResponse) ProtoMessage()

+ func (dst *FragmentsResponse) XXX_Merge(src proto.Message)

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

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

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

+ func (m *FragmentsResponse) Reset()

+ func (m *FragmentsResponse) String() string

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

+ func (m *FragmentsResponse) Validate() error

+ func (m *FragmentsResponse) XXX_DiscardUnknown()

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

+ func (m *FragmentsResponse) XXX_Size() int

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

+ type FragmentsResponse__Fragment struct

+ SignedUrl string

+ Spec Fragment

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

+ func (*FragmentsResponse__Fragment) ProtoMessage()

+ func (dst *FragmentsResponse__Fragment) XXX_Merge(src proto.Message)

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

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

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

+ func (m *FragmentsResponse__Fragment) Reset()

+ func (m *FragmentsResponse__Fragment) String() string

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

+ func (m *FragmentsResponse__Fragment) Validate() error

+ func (m *FragmentsResponse__Fragment) XXX_DiscardUnknown()

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

+ func (m *FragmentsResponse__Fragment) XXX_Size() int

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

+ type Header struct

+ Etcd Header_Etcd

+ ProcessId ProcessSpec_ID

+ Route Route

+ func NewUnroutedHeader(s *allocator.State) (hdr Header)

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

+ func (*Header) ProtoMessage()

+ func (dst *Header) XXX_Merge(src proto.Message)

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

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

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

+ func (m *Header) Reset()

+ func (m *Header) String() string

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

+ func (m *Header) XXX_DiscardUnknown()

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

+ func (m *Header) XXX_Size() int

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

+ func (m Header) Validate() error

+ type Header_Etcd struct

+ ClusterId uint64

+ MemberId uint64

+ RaftTerm uint64

+ Revision int64

+ func FromEtcdResponseHeader(h epb.ResponseHeader) Header_Etcd

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

+ func (*Header_Etcd) ProtoMessage()

+ func (dst *Header_Etcd) XXX_Merge(src proto.Message)

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

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

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

+ func (m *Header_Etcd) Reset()

+ func (m *Header_Etcd) String() string

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

+ func (m *Header_Etcd) XXX_DiscardUnknown()

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

+ func (m *Header_Etcd) XXX_Size() int

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

+ func (m Header_Etcd) Validate() error

+ type Journal string

+ func (n Journal) String() string

+ func (n Journal) Validate() error

+ type JournalClient interface

+ Append func(ctx context.Context, opts ...grpc.CallOption) (Journal_AppendClient, error)

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

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

+ ListFragments func(ctx context.Context, in *FragmentsRequest, opts ...grpc.CallOption) (*FragmentsResponse, error)

+ Read func(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (Journal_ReadClient, error)

+ Replicate func(ctx context.Context, opts ...grpc.CallOption) (Journal_ReplicateClient, error)

+ func NewJournalClient(cc *grpc.ClientConn) JournalClient

+ type JournalServer interface

+ Append func(Journal_AppendServer) error

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

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

+ ListFragments func(context.Context, *FragmentsRequest) (*FragmentsResponse, error)

+ Read func(*ReadRequest, Journal_ReadServer) error

+ Replicate func(Journal_ReplicateServer) error

+ type JournalSpec struct

+ Flags JournalSpec_Flag

+ Fragment JournalSpec_Fragment

+ Name Journal

+ Replication int32

+ func IntersectJournalSpecs(a, b JournalSpec) JournalSpec

+ func SubtractJournalSpecs(a, b JournalSpec) JournalSpec

+ func UnionJournalSpecs(a, b JournalSpec) JournalSpec

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

+ func (*JournalSpec) ProtoMessage()

+ func (dst *JournalSpec) XXX_Merge(src proto.Message)

+ func (m *JournalSpec) DesiredReplication() int

+ func (m *JournalSpec) IsConsistent(_ keyspace.KeyValue, assignments keyspace.KeyValues) bool

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

+ func (m *JournalSpec) MarshalString() string

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

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

+ func (m *JournalSpec) Reset()

+ func (m *JournalSpec) String() string

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

+ func (m *JournalSpec) Validate() error

+ func (m *JournalSpec) XXX_DiscardUnknown()

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

+ func (m *JournalSpec) XXX_Size() int

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

+ type JournalSpec_Flag int32

+ const JournalSpec_NOT_SPECIFIED

+ const JournalSpec_O_RDONLY

+ const JournalSpec_O_RDWR

+ const JournalSpec_O_WRONLY

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

+ func (x *JournalSpec_Flag) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (x JournalSpec_Flag) MarshalYAML() (interface{}, error)

+ func (x JournalSpec_Flag) MayRead() bool

+ func (x JournalSpec_Flag) MayWrite() bool

+ func (x JournalSpec_Flag) String() string

+ func (x JournalSpec_Flag) Validate() error

+ type JournalSpec_Fragment struct

+ CompressionCodec CompressionCodec

+ FlushInterval time.Duration

+ Length int64

+ RefreshInterval time.Duration

+ Retention time.Duration

+ Stores []FragmentStore

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

+ func (*JournalSpec_Fragment) ProtoMessage()

+ func (dst *JournalSpec_Fragment) XXX_Merge(src proto.Message)

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

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

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

+ func (m *JournalSpec_Fragment) Reset()

+ func (m *JournalSpec_Fragment) String() string

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

+ func (m *JournalSpec_Fragment) Validate() error

+ func (m *JournalSpec_Fragment) XXX_DiscardUnknown()

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

+ func (m *JournalSpec_Fragment) XXX_Size() int

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

+ type Journal_AppendClient interface

+ CloseAndRecv func() (*AppendResponse, error)

+ Send func(*AppendRequest) error

+ type Journal_AppendServer interface

+ Recv func() (*AppendRequest, error)

+ SendAndClose func(*AppendResponse) error

+ type Journal_ReadClient interface

+ Recv func() (*ReadResponse, error)

+ type Journal_ReadServer interface

+ Send func(*ReadResponse) error

+ type Journal_ReplicateClient interface

+ Recv func() (*ReplicateResponse, error)

+ Send func(*ReplicateRequest) error

+ type Journal_ReplicateServer interface

+ Recv func() (*ReplicateRequest, error)

+ Send func(*ReplicateResponse) error

+ type Label struct

+ Name string

+ Value string

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

+ func (*Label) ProtoMessage()

+ func (dst *Label) XXX_Merge(src proto.Message)

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

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

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

+ func (m *Label) Reset()

+ func (m *Label) String() string

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

+ func (m *Label) XXX_DiscardUnknown()

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

+ func (m *Label) XXX_Size() int

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

+ func (m Label) Validate() error

+ type LabelSelector struct

+ Exclude LabelSet

+ Include LabelSet

+ func ParseLabelSelector(s string) (LabelSelector, error)

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

+ func (*LabelSelector) ProtoMessage()

+ func (dst *LabelSelector) XXX_Merge(src proto.Message)

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

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

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

+ func (m *LabelSelector) Reset()

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

+ func (m *LabelSelector) XXX_DiscardUnknown()

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

+ func (m *LabelSelector) XXX_Size() int

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

+ func (m LabelSelector) Matches(s LabelSet) bool

+ func (m LabelSelector) Validate() error

+ func (s LabelSelector) String() string

+ type LabelSet struct

+ Labels []Label

+ func ExtractJournalSpecMetaLabels(spec *JournalSpec, out LabelSet) LabelSet

+ func IntersectLabelSets(lhs, rhs, out LabelSet) LabelSet

+ func MustLabelSet(nv ...string) (set LabelSet)

+ func SubtractLabelSet(lhs, rhs, out LabelSet) LabelSet

+ func UnionLabelSets(lhs, rhs, out LabelSet) LabelSet

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

+ func (*LabelSet) ProtoMessage()

+ func (dst *LabelSet) XXX_Merge(src proto.Message)

+ func (m *LabelSet) AddValue(name, value string)

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

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

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

+ func (m *LabelSet) Remove(name string)

+ func (m *LabelSet) Reset()

+ func (m *LabelSet) SetValue(name, value string)

+ func (m *LabelSet) String() string

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

+ func (m *LabelSet) XXX_DiscardUnknown()

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

+ func (m *LabelSet) XXX_Size() int

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

+ func (m LabelSet) Validate() error

+ func (m LabelSet) ValueOf(name string) string

+ func (m LabelSet) ValuesOf(name string) (values []string)

+ type ListRequest struct

+ PageLimit uint32

+ PageToken string

+ Selector LabelSelector

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

+ func (*ListRequest) ProtoMessage()

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

+ 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_Size() int

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

+ type ListResponse struct

+ Header Header

+ Journals []ListResponse_Journal

+ NextPageToken string

+ Status Status

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

+ func (*ListResponse) ProtoMessage()

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

+ 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_Size() int

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

+ type ListResponse_Journal struct

+ ModRevision int64

+ Route Route

+ Spec JournalSpec

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

+ func (*ListResponse_Journal) ProtoMessage()

+ func (dst *ListResponse_Journal) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ListResponse_Journal) Reset()

+ func (m *ListResponse_Journal) String() string

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

+ func (m *ListResponse_Journal) Validate() error

+ func (m *ListResponse_Journal) XXX_DiscardUnknown()

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

+ func (m *ListResponse_Journal) XXX_Size() int

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

+ type NoopDispatchRouter struct

+ func (NoopDispatchRouter) IsNoopRouter() bool

+ func (NoopDispatchRouter) Route(context.Context, string) Route

+ func (NoopDispatchRouter) UpdateRoute(string, *Route)

+ type ProcessSpec struct

+ Endpoint Endpoint

+ Id ProcessSpec_ID

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

+ func (*ProcessSpec) ProtoMessage()

+ func (dst *ProcessSpec) XXX_Merge(src proto.Message)

+ func (m *ProcessSpec) GetEndpoint() Endpoint

+ func (m *ProcessSpec) GetId() ProcessSpec_ID

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

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

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

+ func (m *ProcessSpec) Reset()

+ func (m *ProcessSpec) String() string

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

+ func (m *ProcessSpec) Validate() error

+ func (m *ProcessSpec) XXX_DiscardUnknown()

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

+ func (m *ProcessSpec) XXX_Size() int

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

+ type ProcessSpec_ID struct

+ Suffix string

+ Zone string

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

+ func (*ProcessSpec_ID) ProtoMessage()

+ func (dst *ProcessSpec_ID) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ProcessSpec_ID) Reset()

+ func (m *ProcessSpec_ID) String() string

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

+ func (m *ProcessSpec_ID) XXX_DiscardUnknown()

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

+ func (m *ProcessSpec_ID) XXX_Size() int

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

+ func (m ProcessSpec_ID) Less(other ProcessSpec_ID) bool

+ func (m ProcessSpec_ID) Validate() error

+ type ReadRequest struct

+ Block bool

+ DoNotProxy bool

+ Header *Header

+ Journal Journal

+ MetadataOnly bool

+ Offset int64

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

+ func (*ReadRequest) ProtoMessage()

+ func (dst *ReadRequest) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ReadRequest) Reset()

+ func (m *ReadRequest) String() string

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

+ func (m *ReadRequest) Validate() error

+ func (m *ReadRequest) XXX_DiscardUnknown()

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

+ func (m *ReadRequest) XXX_Size() int

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

+ type ReadResponse struct

+ Content []byte

+ Fragment *Fragment

+ FragmentUrl string

+ Header *Header

+ Offset int64

+ Status Status

+ WriteHead int64

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

+ func (*ReadResponse) ProtoMessage()

+ func (dst *ReadResponse) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ReadResponse) Reset()

+ func (m *ReadResponse) String() string

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

+ func (m *ReadResponse) Validate() error

+ func (m *ReadResponse) XXX_DiscardUnknown()

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

+ func (m *ReadResponse) XXX_Size() int

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

+ type ReplicateRequest struct

+ Acknowledge bool

+ Content []byte

+ ContentDelta int64

+ Header *Header

+ Journal Journal

+ Proposal *Fragment

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

+ func (*ReplicateRequest) ProtoMessage()

+ func (dst *ReplicateRequest) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ReplicateRequest) Reset()

+ func (m *ReplicateRequest) String() string

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

+ func (m *ReplicateRequest) Validate() error

+ func (m *ReplicateRequest) XXX_DiscardUnknown()

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

+ func (m *ReplicateRequest) XXX_Size() int

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

+ type ReplicateResponse struct

+ Fragment *Fragment

+ Header *Header

+ Status Status

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

+ func (*ReplicateResponse) ProtoMessage()

+ func (dst *ReplicateResponse) XXX_Merge(src proto.Message)

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

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

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

+ func (m *ReplicateResponse) Reset()

+ func (m *ReplicateResponse) String() string

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

+ func (m *ReplicateResponse) Validate() error

+ func (m *ReplicateResponse) XXX_DiscardUnknown()

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

+ func (m *ReplicateResponse) XXX_Size() int

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

+ type Route struct

+ Endpoints []Endpoint

+ Members []ProcessSpec_ID

+ Primary int32

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

+ func (*Route) ProtoMessage()

+ func (dst *Route) XXX_Merge(src proto.Message)

+ func (m *Route) AttachEndpoints(ks *keyspace.KeySpace)

+ func (m *Route) Init(assignments keyspace.KeyValues)

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

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

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

+ func (m *Route) Reset()

+ func (m *Route) String() string

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

+ func (m *Route) XXX_DiscardUnknown()

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

+ func (m *Route) XXX_Size() int

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

+ func (m Route) Copy() Route

+ func (m Route) Equivalent(other *Route) bool

+ func (m Route) MarshalString() string

+ func (m Route) Validate() error

+ type RoutedJournalClient interface

+ func NewRoutedJournalClient(jc JournalClient, dr DispatchRouter) RoutedJournalClient

+ type SHA1Sum struct

+ Part1 uint64

+ Part2 uint64

+ Part3 uint32

+ func SHA1SumFromDigest(r []byte) SHA1Sum

+ func SHA1SumOf(str string) SHA1Sum

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

+ func (*SHA1Sum) ProtoMessage()

+ func (dst *SHA1Sum) XXX_Merge(src proto.Message)

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

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

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

+ func (m *SHA1Sum) Reset()

+ func (m *SHA1Sum) String() string

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

+ func (m *SHA1Sum) XXX_DiscardUnknown()

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

+ func (m *SHA1Sum) XXX_Size() int

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

+ func (m SHA1Sum) IsZero() bool

+ func (m SHA1Sum) ToDigest() (r [20]byte)

+ type Status int32

+ const Status_ETCD_TRANSACTION_FAILED

+ const Status_FRAGMENT_MISMATCH

+ const Status_INDEX_HAS_GREATER_OFFSET

+ const Status_INSUFFICIENT_JOURNAL_BROKERS

+ const Status_JOURNAL_NOT_FOUND

+ const Status_NOT_ALLOWED

+ const Status_NOT_JOURNAL_BROKER

+ const Status_NOT_JOURNAL_PRIMARY_BROKER

+ const Status_NO_JOURNAL_PRIMARY_BROKER

+ const Status_OFFSET_NOT_YET_AVAILABLE

+ const Status_OK

+ const Status_WRONG_APPEND_OFFSET

+ const Status_WRONG_ROUTE

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

+ func (x Status) String() string

+ func (x Status) Validate() error

+ type ValidationError struct

+ Context []string

+ Err error

+ func (ve *ValidationError) Error() string

+ type Validator interface

+ Validate func() error

Incompatible versions in this module

v2.0.212+incompatible

May 15, 2019

v2.0.211+incompatible

May 15, 2019

v2.0.210+incompatible

Apr 24, 2019

v2.0.209+incompatible

Apr 5, 2019

v2.0.208+incompatible

Mar 21, 2019

v2.0.207+incompatible

Mar 20, 2019

v2.0.206+incompatible

Mar 20, 2019

v2.0.205+incompatible

Mar 20, 2019

v2.0.204+incompatible

Mar 13, 2019

v2.0.203+incompatible

Mar 12, 2019

v2.0.202+incompatible

Feb 24, 2019

v2.0.201+incompatible

Feb 13, 2019

v2.0.200+incompatible

Feb 2, 2019

v2.0.100+incompatible

Jan 7, 2019

v2.0.0+incompatible

Jan 7, 2019