internal

type AddRequest struct {
	HostId      string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	ShardId     uint64 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	ReplicaId   uint64 `protobuf:"varint,3,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
	IsNonVoting bool   `protobuf:"varint,4,opt,name=is_non_voting,json=isNonVoting,proto3" json:"is_non_voting,omitempty"`
	// contains filtered or unexported fields
}

type AddResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ApplyRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Data    []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ApplyResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type CommitRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Data    []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type IndexRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// contains filtered or unexported fields
}

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

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

type InfoResponse struct {
	HostId    string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	ReplicaId uint64 `protobuf:"varint,2,opt,name=replica_id,json=replicaId,proto3" json:"replica_id,omitempty"`
	// contains filtered or unexported fields
}

type InternalClient interface {
	// Ping is a noop for timing purposes
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Probe returns Gossip.AdvertiseAddress
	// Used by new hosts to start dragonboat
	Probe(ctx context.Context, in *ProbeRequest, opts ...grpc.CallOption) (*ProbeResponse, error)
	// Info returns zero shard replicaID and hostID
	// Used by new hosts to discover zero shard replicas
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	// Members returns json marshaled map of member zero shard replicaID to hostID
	// Used by new hosts joining a bootstrapped zero shard
	Members(ctx context.Context, in *MembersRequest, opts ...grpc.CallOption) (*MembersResponse, error)
	// Join takes a host ID and returns success
	// Used by joining hosts to request their own addition to the zero shard
	Join(ctx context.Context, in *JoinRequest, opts ...grpc.CallOption) (*JoinResponse, error)
	// Add takes a replica ID, shard ID and host ID and returns success
	// Used during replica creation to request replica's addition to the shard
	Add(ctx context.Context, in *AddRequest, opts ...grpc.CallOption) (*AddResponse, error)
	// Index reads the index of a shard
	Index(ctx context.Context, in *IndexRequest, opts ...grpc.CallOption) (*IndexResponse, error)
	// Apply provides unary request/response command forwarding
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	// Commit provides unary request/response command forwarding
	Commit(ctx context.Context, in *CommitRequest, opts ...grpc.CallOption) (*CommitResponse, error)
	// Read provides unary request/response query forwarding
	Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error)
	// Watch provides streaming query response forwarding
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[WatchResponse], error)
	// Stream provides streaming proposal forwarding
	Stream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[StreamRequest, StreamResponse], error)
}

type InternalServer interface {
	// Ping is a noop for timing purposes
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Probe returns Gossip.AdvertiseAddress
	// Used by new hosts to start dragonboat
	Probe(context.Context, *ProbeRequest) (*ProbeResponse, error)
	// Info returns zero shard replicaID and hostID
	// Used by new hosts to discover zero shard replicas
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	// Members returns json marshaled map of member zero shard replicaID to hostID
	// Used by new hosts joining a bootstrapped zero shard
	Members(context.Context, *MembersRequest) (*MembersResponse, error)
	// Join takes a host ID and returns success
	// Used by joining hosts to request their own addition to the zero shard
	Join(context.Context, *JoinRequest) (*JoinResponse, error)
	// Add takes a replica ID, shard ID and host ID and returns success
	// Used during replica creation to request replica's addition to the shard
	Add(context.Context, *AddRequest) (*AddResponse, error)
	// Index reads the index of a shard
	Index(context.Context, *IndexRequest) (*IndexResponse, error)
	// Apply provides unary request/response command forwarding
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	// Commit provides unary request/response command forwarding
	Commit(context.Context, *CommitRequest) (*CommitResponse, error)
	// Read provides unary request/response query forwarding
	Read(context.Context, *ReadRequest) (*ReadResponse, error)
	// Watch provides streaming query response forwarding
	Watch(*WatchRequest, grpc.ServerStreamingServer[WatchResponse]) error
	// Stream provides streaming proposal forwarding
	Stream(grpc.BidiStreamingServer[StreamRequest, StreamResponse]) error
	// contains filtered or unexported methods
}

type Internal_StreamClient = grpc.BidiStreamingClient[StreamRequest, StreamResponse]

type Internal_StreamServer = grpc.BidiStreamingServer[StreamRequest, StreamResponse]

type Internal_WatchClient = grpc.ServerStreamingClient[WatchResponse]

type Internal_WatchServer = grpc.ServerStreamingServer[WatchResponse]

type JoinRequest struct {
	HostId      string `protobuf:"bytes,1,opt,name=host_id,json=hostId,proto3" json:"host_id,omitempty"`
	IsNonVoting bool   `protobuf:"varint,2,opt,name=is_non_voting,json=isNonVoting,proto3" json:"is_non_voting,omitempty"`
	// contains filtered or unexported fields
}

type JoinResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

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

type MembersResponse struct {
	Members map[uint64]string `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

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

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

type ProbeResponse struct {
	GossipAdvertiseAddress string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ReadRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Stale   bool   `protobuf:"varint,2,opt,name=stale,proto3" json:"stale,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type ReadResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type StreamConnect struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Stale   bool   `protobuf:"varint,2,opt,name=stale,proto3" json:"stale,omitempty"`
	// contains filtered or unexported fields
}

type StreamMessage struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Data    []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type StreamRequest struct {

	// Types that are valid to be assigned to RequestUnion:
	//
	//	*StreamRequest_StreamConnect
	//	*StreamRequest_StreamMessage
	RequestUnion isStreamRequest_RequestUnion `protobuf_oneof:"request_union"`
	// contains filtered or unexported fields
}

type StreamRequest_StreamConnect struct {
	StreamConnect *StreamConnect `protobuf:"bytes,1,opt,name=stream_connect,json=streamConnect,proto3,oneof"`
}

type StreamRequest_StreamMessage struct {
	StreamMessage *StreamMessage `protobuf:"bytes,2,opt,name=stream_message,json=streamMessage,proto3,oneof"`
}

type StreamResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedInternalServer struct{}

type UnsafeInternalServer interface {
	// contains filtered or unexported methods
}

type WatchRequest struct {
	ShardId uint64 `protobuf:"varint,1,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Stale   bool   `protobuf:"varint,2,opt,name=stale,proto3" json:"stale,omitempty"`
	Data    []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type WatchResponse struct {
	Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	Data  []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}