replicationtypes

package
v2.313.0 Latest Latest
Warning

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

 Go to latest Published: Oct 28, 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 (m *ReplicateGlobalStats_Request) String() 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 (m *ReplicateGroupStats_Reply) GetGroup() *ReplicatedGroup

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"`
	CreatedAt            int64  `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt            int64  `protobuf:"varint,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	MetadataEntriesCount int64  `protobuf:"varint,5,opt,name=metadata_entries_count,json=metadataEntriesCount,proto3" json:"metadata_entries_count,omitempty"`
	MetadataLatestHead   string `protobuf:"bytes,6,opt,name=metadata_latest_head,json=metadataLatestHead,proto3" json:"metadata_latest_head,omitempty"`
	MessageEntriesCount  int64  `protobuf:"varint,7,opt,name=message_entries_count,json=messageEntriesCount,proto3" json:"message_entries_count,omitempty"`
	MessageLatestHead    string `protobuf:"bytes,8,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) 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 (m *ReplicationServiceReplicateGroup) Reset()

func (*ReplicationServiceReplicateGroup) Size 

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

func (*ReplicationServiceReplicateGroup) String 

func (m *ReplicationServiceReplicateGroup) String() 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 (m *ReplicationServiceReplicateGroup) XXX_Merge(src proto.Message)

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 (m *ReplicationServiceReplicateGroup_Reply) GetOK() bool

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) ProtoMessage()

func (*ReplicationServiceReplicateGroup_Reply) Reset 

func (m *ReplicationServiceReplicateGroup_Reply) Reset()

func (*ReplicationServiceReplicateGroup_Reply) Size 

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

func (*ReplicationServiceReplicateGroup_Reply) String 

func (m *ReplicationServiceReplicateGroup_Reply) String() 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 (m *ReplicationServiceReplicateGroup_Reply) XXX_Merge(src proto.Message)

func (*ReplicationServiceReplicateGroup_Reply) XXX_Size 

func (m *ReplicationServiceReplicateGroup_Reply) XXX_Size() int

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 (m *ReplicationServiceReplicateGroup_Request) GetGroup() *protocoltypes.Group

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) ProtoMessage()

func (*ReplicationServiceReplicateGroup_Request) Reset 

func (m *ReplicationServiceReplicateGroup_Request) Reset()

func (*ReplicationServiceReplicateGroup_Request) Size 

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

func (*ReplicationServiceReplicateGroup_Request) String 

func (m *ReplicationServiceReplicateGroup_Request) String() string

func (*ReplicationServiceReplicateGroup_Request) Unmarshal 

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

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 (m *ReplicationServiceReplicateGroup_Request) XXX_Merge(src proto.Message)

func (*ReplicationServiceReplicateGroup_Request) XXX_Size 

func (m *ReplicationServiceReplicateGroup_Request) XXX_Size() int

func (*ReplicationServiceReplicateGroup_Request) XXX_Unmarshal 

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

type ReplicationServiceServer 

type ReplicationServiceServer interface {
	// ReplicateGroup
	ReplicateGroup(context.Context, *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error)
	ReplicateGlobalStats(context.Context, *ReplicateGlobalStats_Request) (*ReplicateGlobalStats_Reply, error)
	ReplicateGroupStats(context.Context, *ReplicateGroupStats_Request) (*ReplicateGroupStats_Reply, error)
}

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) ReplicateGlobalStats(ctx context.Context, req *ReplicateGlobalStats_Request) (*ReplicateGlobalStats_Reply, error)

func (*UnimplementedReplicationServiceServer) ReplicateGroup 

func (*UnimplementedReplicationServiceServer) ReplicateGroup(ctx context.Context, req *ReplicationServiceReplicateGroup_Request) (*ReplicationServiceReplicateGroup_Reply, error)

func (*UnimplementedReplicationServiceServer) ReplicateGroupStats 

func (*UnimplementedReplicationServiceServer) ReplicateGroupStats(ctx context.Context, req *ReplicateGroupStats_Request) (*ReplicateGroupStats_Reply, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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