replicationtypes

package
v2.328.7 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2021 License: Apache-2.0, MIT Imports: 19 Imported by: 0

Documentation

Overview

Package replicationtypes is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	ServiceReplicationRegisteredPrefix = "user_registration"
	ServiceReplicationKeyGroupPrefix   = "group"
)

Variables

View Source
var (
	ErrInvalidLengthBertyreplication        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBertyreplication          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBertyreplication = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterReplicationServiceHandler

func RegisterReplicationServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterReplicationServiceHandler registers the http handlers for service ReplicationService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterReplicationServiceHandlerClient

func RegisterReplicationServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ReplicationServiceClient) error

RegisterReplicationServiceHandlerClient registers the http handlers for service ReplicationService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ReplicationServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ReplicationServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ReplicationServiceClient" to call the correct interceptors.

func RegisterReplicationServiceHandlerFromEndpoint

func RegisterReplicationServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterReplicationServiceHandlerFromEndpoint is same as RegisterReplicationServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterReplicationServiceHandlerServer

func RegisterReplicationServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ReplicationServiceServer) error

RegisterReplicationServiceHandlerServer registers the http handlers for service ReplicationService to "mux". UnaryRPC :call ReplicationServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterReplicationServiceHandlerFromEndpoint instead.

func RegisterReplicationServiceServer

func RegisterReplicationServiceServer(s *grpc.Server, srv ReplicationServiceServer)

Types

type ReplicateGlobalStats

type ReplicateGlobalStats struct{}

func (*ReplicateGlobalStats) Descriptor

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

func (*ReplicateGlobalStats) Marshal

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

func (*ReplicateGlobalStats) MarshalTo

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

func (*ReplicateGlobalStats) MarshalToSizedBuffer

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

func (*ReplicateGlobalStats) ProtoMessage

func (*ReplicateGlobalStats) ProtoMessage()

func (*ReplicateGlobalStats) Reset

func (m *ReplicateGlobalStats) Reset()

func (*ReplicateGlobalStats) Size

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

func (*ReplicateGlobalStats) String

func (m *ReplicateGlobalStats) String() string

func (*ReplicateGlobalStats) Unmarshal

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

func (*ReplicateGlobalStats) XXX_DiscardUnknown

func (m *ReplicateGlobalStats) XXX_DiscardUnknown()

func (*ReplicateGlobalStats) XXX_Marshal

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

func (*ReplicateGlobalStats) XXX_Merge

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

func (*ReplicateGlobalStats) XXX_Size

func (m *ReplicateGlobalStats) XXX_Size() int

func (*ReplicateGlobalStats) XXX_Unmarshal

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

type ReplicateGlobalStats_Reply

type ReplicateGlobalStats_Reply struct {
	StartedAt            int64 `protobuf:"varint,1,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	ReplicatedGroups     int64 `protobuf:"varint,2,opt,name=replicated_groups,json=replicatedGroups,proto3" json:"replicated_groups,omitempty"`
	TotalMetadataEntries int64 `protobuf:"varint,3,opt,name=total_metadata_entries,json=totalMetadataEntries,proto3" json:"total_metadata_entries,omitempty"`
	TotalMessageEntries  int64 `protobuf:"varint,4,opt,name=total_message_entries,json=totalMessageEntries,proto3" json:"total_message_entries,omitempty"`
}

func (*ReplicateGlobalStats_Reply) Descriptor

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

func (*ReplicateGlobalStats_Reply) GetReplicatedGroups

func (m *ReplicateGlobalStats_Reply) GetReplicatedGroups() int64

func (*ReplicateGlobalStats_Reply) GetStartedAt

func (m *ReplicateGlobalStats_Reply) GetStartedAt() int64

func (*ReplicateGlobalStats_Reply) GetTotalMessageEntries

func (m *ReplicateGlobalStats_Reply) GetTotalMessageEntries() int64

func (*ReplicateGlobalStats_Reply) GetTotalMetadataEntries

func (m *ReplicateGlobalStats_Reply) GetTotalMetadataEntries() int64

func (*ReplicateGlobalStats_Reply) Marshal

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

func (*ReplicateGlobalStats_Reply) MarshalTo

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

func (*ReplicateGlobalStats_Reply) MarshalToSizedBuffer

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

func (*ReplicateGlobalStats_Reply) ProtoMessage

func (*ReplicateGlobalStats_Reply) ProtoMessage()

func (*ReplicateGlobalStats_Reply) Reset

func (m *ReplicateGlobalStats_Reply) Reset()

func (*ReplicateGlobalStats_Reply) Size

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

func (*ReplicateGlobalStats_Reply) String

func (m *ReplicateGlobalStats_Reply) String() string

func (*ReplicateGlobalStats_Reply) Unmarshal

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

func (*ReplicateGlobalStats_Reply) XXX_DiscardUnknown

func (m *ReplicateGlobalStats_Reply) XXX_DiscardUnknown()

func (*ReplicateGlobalStats_Reply) XXX_Marshal

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

func (*ReplicateGlobalStats_Reply) XXX_Merge

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

func (*ReplicateGlobalStats_Reply) XXX_Size

func (m *ReplicateGlobalStats_Reply) XXX_Size() int

func (*ReplicateGlobalStats_Reply) XXX_Unmarshal

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

type ReplicateGlobalStats_Request

type ReplicateGlobalStats_Request struct{}

func (*ReplicateGlobalStats_Request) Descriptor

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

func (*ReplicateGlobalStats_Request) Marshal

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

func (*ReplicateGlobalStats_Request) MarshalTo

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

func (*ReplicateGlobalStats_Request) MarshalToSizedBuffer

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

func (*ReplicateGlobalStats_Request) ProtoMessage

func (*ReplicateGlobalStats_Request) ProtoMessage()

func (*ReplicateGlobalStats_Request) Reset

func (m *ReplicateGlobalStats_Request) Reset()

func (*ReplicateGlobalStats_Request) Size

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

func (*ReplicateGlobalStats_Request) String

func (*ReplicateGlobalStats_Request) Unmarshal

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

func (*ReplicateGlobalStats_Request) XXX_DiscardUnknown

func (m *ReplicateGlobalStats_Request) XXX_DiscardUnknown()

func (*ReplicateGlobalStats_Request) XXX_Marshal

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

func (*ReplicateGlobalStats_Request) XXX_Merge

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

func (*ReplicateGlobalStats_Request) XXX_Size

func (m *ReplicateGlobalStats_Request) XXX_Size() int

func (*ReplicateGlobalStats_Request) XXX_Unmarshal

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

type ReplicateGroupStats

type ReplicateGroupStats struct{}

func (*ReplicateGroupStats) Descriptor

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

func (*ReplicateGroupStats) Marshal

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

func (*ReplicateGroupStats) MarshalTo

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

func (*ReplicateGroupStats) MarshalToSizedBuffer

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

func (*ReplicateGroupStats) ProtoMessage

func (*ReplicateGroupStats) ProtoMessage()

func (*ReplicateGroupStats) Reset

func (m *ReplicateGroupStats) Reset()

func (*ReplicateGroupStats) Size

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

func (*ReplicateGroupStats) String

func (m *ReplicateGroupStats) String() string

func (*ReplicateGroupStats) Unmarshal

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

func (*ReplicateGroupStats) XXX_DiscardUnknown

func (m *ReplicateGroupStats) XXX_DiscardUnknown()

func (*ReplicateGroupStats) XXX_Marshal

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

func (*ReplicateGroupStats) XXX_Merge

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

func (*ReplicateGroupStats) XXX_Size

func (m *ReplicateGroupStats) XXX_Size() int

func (*ReplicateGroupStats) XXX_Unmarshal

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

type ReplicateGroupStats_Reply

type ReplicateGroupStats_Reply struct {
	Group *ReplicatedGroup `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}

func (*ReplicateGroupStats_Reply) Descriptor

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

func (*ReplicateGroupStats_Reply) GetGroup

func (*ReplicateGroupStats_Reply) Marshal

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

func (*ReplicateGroupStats_Reply) MarshalTo

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

func (*ReplicateGroupStats_Reply) MarshalToSizedBuffer

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

func (*ReplicateGroupStats_Reply) ProtoMessage

func (*ReplicateGroupStats_Reply) ProtoMessage()

func (*ReplicateGroupStats_Reply) Reset

func (m *ReplicateGroupStats_Reply) Reset()

func (*ReplicateGroupStats_Reply) Size

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

func (*ReplicateGroupStats_Reply) String

func (m *ReplicateGroupStats_Reply) String() string

func (*ReplicateGroupStats_Reply) Unmarshal

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

func (*ReplicateGroupStats_Reply) XXX_DiscardUnknown

func (m *ReplicateGroupStats_Reply) XXX_DiscardUnknown()

func (*ReplicateGroupStats_Reply) XXX_Marshal

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

func (*ReplicateGroupStats_Reply) XXX_Merge

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

func (*ReplicateGroupStats_Reply) XXX_Size

func (m *ReplicateGroupStats_Reply) XXX_Size() int

func (*ReplicateGroupStats_Reply) XXX_Unmarshal

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

type ReplicateGroupStats_Request

type ReplicateGroupStats_Request struct {
	GroupPublicKey string `protobuf:"bytes,1,opt,name=group_public_key,json=groupPublicKey,proto3" json:"group_public_key,omitempty"`
}

func (*ReplicateGroupStats_Request) Descriptor

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

func (*ReplicateGroupStats_Request) GetGroupPublicKey

func (m *ReplicateGroupStats_Request) GetGroupPublicKey() string

func (*ReplicateGroupStats_Request) Marshal

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

func (*ReplicateGroupStats_Request) MarshalTo

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

func (*ReplicateGroupStats_Request) MarshalToSizedBuffer

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

func (*ReplicateGroupStats_Request) ProtoMessage

func (*ReplicateGroupStats_Request) ProtoMessage()

func (*ReplicateGroupStats_Request) Reset

func (m *ReplicateGroupStats_Request) Reset()

func (*ReplicateGroupStats_Request) Size

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

func (*ReplicateGroupStats_Request) String

func (m *ReplicateGroupStats_Request) String() string

func (*ReplicateGroupStats_Request) Unmarshal

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

func (*ReplicateGroupStats_Request) XXX_DiscardUnknown

func (m *ReplicateGroupStats_Request) XXX_DiscardUnknown()

func (*ReplicateGroupStats_Request) XXX_Marshal

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

func (*ReplicateGroupStats_Request) XXX_Merge

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

func (*ReplicateGroupStats_Request) XXX_Size

func (m *ReplicateGroupStats_Request) XXX_Size() int

func (*ReplicateGroupStats_Request) XXX_Unmarshal

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

type ReplicatedGroup

type ReplicatedGroup struct {
	PublicKey            string `protobuf:"bytes,1,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty" gorm:"primaryKey"`
	SignPub              string `protobuf:"bytes,2,opt,name=sign_pub,json=signPub,proto3" json:"sign_pub,omitempty"`
	LinkKey              string `protobuf:"bytes,3,opt,name=link_key,json=linkKey,proto3" json:"link_key,omitempty"`
	CreatedAt            int64  `protobuf:"varint,100,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            int64  `protobuf:"varint,101,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	MetadataEntriesCount int64  `` /* 126-byte string literal not displayed */
	MetadataLatestHead   string `protobuf:"bytes,103,opt,name=metadata_latest_head,json=metadataLatestHead,proto3" json:"metadata_latest_head,omitempty"`
	MessageEntriesCount  int64  `protobuf:"varint,104,opt,name=message_entries_count,json=messageEntriesCount,proto3" json:"message_entries_count,omitempty"`
	MessageLatestHead    string `protobuf:"bytes,105,opt,name=message_latest_head,json=messageLatestHead,proto3" json:"message_latest_head,omitempty"`
}

func (*ReplicatedGroup) Descriptor

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

func (*ReplicatedGroup) GetCreatedAt

func (m *ReplicatedGroup) GetCreatedAt() int64

func (*ReplicatedGroup) GetLinkKey added in v2.318.0

func (m *ReplicatedGroup) GetLinkKey() string

func (*ReplicatedGroup) GetMessageEntriesCount

func (m *ReplicatedGroup) GetMessageEntriesCount() int64

func (*ReplicatedGroup) GetMessageLatestHead

func (m *ReplicatedGroup) GetMessageLatestHead() string

func (*ReplicatedGroup) GetMetadataEntriesCount

func (m *ReplicatedGroup) GetMetadataEntriesCount() int64

func (*ReplicatedGroup) GetMetadataLatestHead

func (m *ReplicatedGroup) GetMetadataLatestHead() string

func (*ReplicatedGroup) GetPublicKey

func (m *ReplicatedGroup) GetPublicKey() string

func (*ReplicatedGroup) GetSignPub

func (m *ReplicatedGroup) GetSignPub() string

func (*ReplicatedGroup) GetUpdatedAt

func (m *ReplicatedGroup) GetUpdatedAt() int64

func (*ReplicatedGroup) Marshal

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

func (*ReplicatedGroup) MarshalTo

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

func (*ReplicatedGroup) MarshalToSizedBuffer

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

func (*ReplicatedGroup) ProtoMessage

func (*ReplicatedGroup) ProtoMessage()

func (*ReplicatedGroup) Reset

func (m *ReplicatedGroup) Reset()

func (*ReplicatedGroup) Size

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

func (*ReplicatedGroup) String

func (m *ReplicatedGroup) String() string

func (*ReplicatedGroup) ToGroup

func (m *ReplicatedGroup) ToGroup() (*protocoltypes.Group, error)

func (*ReplicatedGroup) Unmarshal

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

func (*ReplicatedGroup) XXX_DiscardUnknown

func (m *ReplicatedGroup) XXX_DiscardUnknown()

func (*ReplicatedGroup) XXX_Marshal

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

func (*ReplicatedGroup) XXX_Merge

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

func (*ReplicatedGroup) XXX_Size

func (m *ReplicatedGroup) XXX_Size() int

func (*ReplicatedGroup) XXX_Unmarshal

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

type ReplicatedGroupToken

type ReplicatedGroupToken struct {
	ReplicatedGroupPublicKey string           `` /* 181-byte string literal not displayed */
	ReplicatedGroup          *ReplicatedGroup `protobuf:"bytes,2,opt,name=replicated_group,json=replicatedGroup,proto3" json:"replicated_group,omitempty"`
	TokenIssuer              string           `` /* 132-byte string literal not displayed */
	TokenID                  string           `protobuf:"bytes,4,opt,name=token_id,json=tokenId,proto3" json:"token_id,omitempty" gorm:"primaryKey;autoIncrement:false"`
	CreatedAt                int64            `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
}

func (*ReplicatedGroupToken) Descriptor

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

func (*ReplicatedGroupToken) GetCreatedAt

func (m *ReplicatedGroupToken) GetCreatedAt() int64

func (*ReplicatedGroupToken) GetReplicatedGroup

func (m *ReplicatedGroupToken) GetReplicatedGroup() *ReplicatedGroup

func (*ReplicatedGroupToken) GetReplicatedGroupPublicKey

func (m *ReplicatedGroupToken) GetReplicatedGroupPublicKey() string

func (*ReplicatedGroupToken) GetTokenID

func (m *ReplicatedGroupToken) GetTokenID() string

func (*ReplicatedGroupToken) GetTokenIssuer

func (m *ReplicatedGroupToken) GetTokenIssuer() string

func (*ReplicatedGroupToken) Marshal

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

func (*ReplicatedGroupToken) MarshalTo

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

func (*ReplicatedGroupToken) MarshalToSizedBuffer

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

func (*ReplicatedGroupToken) ProtoMessage

func (*ReplicatedGroupToken) ProtoMessage()

func (*ReplicatedGroupToken) Reset

func (m *ReplicatedGroupToken) Reset()

func (*ReplicatedGroupToken) Size

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

func (*ReplicatedGroupToken) String

func (m *ReplicatedGroupToken) String() string

func (*ReplicatedGroupToken) Unmarshal

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

func (*ReplicatedGroupToken) XXX_DiscardUnknown

func (m *ReplicatedGroupToken) XXX_DiscardUnknown()

func (*ReplicatedGroupToken) XXX_Marshal

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

func (*ReplicatedGroupToken) XXX_Merge

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

func (*ReplicatedGroupToken) XXX_Size

func (m *ReplicatedGroupToken) XXX_Size() int

func (*ReplicatedGroupToken) XXX_Unmarshal

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

type ReplicationServiceClient

type ReplicationServiceClient interface {
	// ReplicateGroup
	ReplicateGroup(ctx context.Context, in *ReplicationServiceReplicateGroup_Request, opts ...grpc.CallOption) (*ReplicationServiceReplicateGroup_Reply, error)
	ReplicateGlobalStats(ctx context.Context, in *ReplicateGlobalStats_Request, opts ...grpc.CallOption) (*ReplicateGlobalStats_Reply, error)
	ReplicateGroupStats(ctx context.Context, in *ReplicateGroupStats_Request, opts ...grpc.CallOption) (*ReplicateGroupStats_Reply, error)
}

ReplicationServiceClient is the client API for ReplicationService service.

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

func NewReplicationServiceClient

func NewReplicationServiceClient(cc *grpc.ClientConn) ReplicationServiceClient

type ReplicationServiceReplicateGroup

type ReplicationServiceReplicateGroup struct{}

func (*ReplicationServiceReplicateGroup) Descriptor

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

func (*ReplicationServiceReplicateGroup) Marshal

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

func (*ReplicationServiceReplicateGroup) MarshalTo

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

func (*ReplicationServiceReplicateGroup) MarshalToSizedBuffer

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

func (*ReplicationServiceReplicateGroup) ProtoMessage

func (*ReplicationServiceReplicateGroup) ProtoMessage()

func (*ReplicationServiceReplicateGroup) Reset

func (*ReplicationServiceReplicateGroup) Size

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

func (*ReplicationServiceReplicateGroup) String

func (*ReplicationServiceReplicateGroup) Unmarshal

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

func (*ReplicationServiceReplicateGroup) XXX_DiscardUnknown

func (m *ReplicationServiceReplicateGroup) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup) XXX_Marshal

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

func (*ReplicationServiceReplicateGroup) XXX_Merge

func (*ReplicationServiceReplicateGroup) XXX_Size

func (m *ReplicationServiceReplicateGroup) XXX_Size() int

func (*ReplicationServiceReplicateGroup) XXX_Unmarshal

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

type ReplicationServiceReplicateGroup_Reply

type ReplicationServiceReplicateGroup_Reply struct {
	OK bool `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
}

func (*ReplicationServiceReplicateGroup_Reply) Descriptor

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

func (*ReplicationServiceReplicateGroup_Reply) GetOK

func (*ReplicationServiceReplicateGroup_Reply) Marshal

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

func (*ReplicationServiceReplicateGroup_Reply) MarshalTo

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

func (*ReplicationServiceReplicateGroup_Reply) MarshalToSizedBuffer

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

func (*ReplicationServiceReplicateGroup_Reply) ProtoMessage

func (*ReplicationServiceReplicateGroup_Reply) Reset

func (*ReplicationServiceReplicateGroup_Reply) Size

func (*ReplicationServiceReplicateGroup_Reply) String

func (*ReplicationServiceReplicateGroup_Reply) Unmarshal

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

func (*ReplicationServiceReplicateGroup_Reply) XXX_DiscardUnknown

func (m *ReplicationServiceReplicateGroup_Reply) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup_Reply) XXX_Marshal

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

func (*ReplicationServiceReplicateGroup_Reply) XXX_Merge

func (*ReplicationServiceReplicateGroup_Reply) XXX_Size

func (*ReplicationServiceReplicateGroup_Reply) XXX_Unmarshal

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

type ReplicationServiceReplicateGroup_Request

type ReplicationServiceReplicateGroup_Request struct {
	Group *protocoltypes.Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
}

func (*ReplicationServiceReplicateGroup_Request) Descriptor

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

func (*ReplicationServiceReplicateGroup_Request) GetGroup

func (*ReplicationServiceReplicateGroup_Request) Marshal

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

func (*ReplicationServiceReplicateGroup_Request) MarshalTo

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

func (*ReplicationServiceReplicateGroup_Request) MarshalToSizedBuffer

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

func (*ReplicationServiceReplicateGroup_Request) ProtoMessage

func (*ReplicationServiceReplicateGroup_Request) Reset

func (*ReplicationServiceReplicateGroup_Request) Size

func (*ReplicationServiceReplicateGroup_Request) String

func (*ReplicationServiceReplicateGroup_Request) Unmarshal

func (*ReplicationServiceReplicateGroup_Request) XXX_DiscardUnknown

func (m *ReplicationServiceReplicateGroup_Request) XXX_DiscardUnknown()

func (*ReplicationServiceReplicateGroup_Request) XXX_Marshal

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

func (*ReplicationServiceReplicateGroup_Request) XXX_Merge

func (*ReplicationServiceReplicateGroup_Request) XXX_Size

func (*ReplicationServiceReplicateGroup_Request) XXX_Unmarshal

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

type ReplicationServiceServer

ReplicationServiceServer is the server API for ReplicationService service.

type UnimplementedReplicationServiceServer

type UnimplementedReplicationServiceServer struct{}

UnimplementedReplicationServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedReplicationServiceServer) ReplicateGlobalStats

func (*UnimplementedReplicationServiceServer) ReplicateGroupStats

Jump to

Keyboard shortcuts

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