rpc

package
Version: v0.0.0-...-b2a47e0 Latest Latest
Warning

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

Go to latest
Published: May 20, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

Functions

func RegisterMSTManagerServiceServer

func RegisterMSTManagerServiceServer(s *grpc.Server, srv MSTManagerServiceServer)

func RegisterMSTServiceServer

func RegisterMSTServiceServer(s *grpc.Server, srv MSTServiceServer)

Types

type MSTChild

type MSTChild struct {
	Key   []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	High  []byte `protobuf:"bytes,3,opt,name=high,proto3" json:"high,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTChild) Descriptor deprecated

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

Deprecated: Use MSTChild.ProtoReflect.Descriptor instead.

func (*MSTChild) GetHigh

func (x *MSTChild) GetHigh() []byte

func (*MSTChild) GetKey

func (x *MSTChild) GetKey() []byte

func (*MSTChild) GetValue

func (x *MSTChild) GetValue() []byte

func (*MSTChild) ProtoMessage

func (*MSTChild) ProtoMessage()

func (*MSTChild) ProtoReflect

func (x *MSTChild) ProtoReflect() protoreflect.Message

func (*MSTChild) Reset

func (x *MSTChild) Reset()

func (*MSTChild) String

func (x *MSTChild) String() string

type MSTGetRequest

type MSTGetRequest struct {
	Key uint32 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTGetRequest) Descriptor deprecated

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

Deprecated: Use MSTGetRequest.ProtoReflect.Descriptor instead.

func (*MSTGetRequest) GetKey

func (x *MSTGetRequest) GetKey() uint32

func (*MSTGetRequest) ProtoMessage

func (*MSTGetRequest) ProtoMessage()

func (*MSTGetRequest) ProtoReflect

func (x *MSTGetRequest) ProtoReflect() protoreflect.Message

func (*MSTGetRequest) Reset

func (x *MSTGetRequest) Reset()

func (*MSTGetRequest) String

func (x *MSTGetRequest) String() string

type MSTGetResponse

type MSTGetResponse struct {
	Value uint32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTGetResponse) Descriptor deprecated

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

Deprecated: Use MSTGetResponse.ProtoReflect.Descriptor instead.

func (*MSTGetResponse) GetValue

func (x *MSTGetResponse) GetValue() uint32

func (*MSTGetResponse) ProtoMessage

func (*MSTGetResponse) ProtoMessage()

func (*MSTGetResponse) ProtoReflect

func (x *MSTGetResponse) ProtoReflect() protoreflect.Message

func (*MSTGetResponse) Reset

func (x *MSTGetResponse) Reset()

func (*MSTGetResponse) String

func (x *MSTGetResponse) String() string

type MSTManagerServiceClient

type MSTManagerServiceClient interface {
	RoundStart(ctx context.Context, in *MSTRoundStartRequest, opts ...grpc.CallOption) (*MSTRoundStepResponse, error)
	RoundStep(ctx context.Context, in *MSTRoundStepRequest, opts ...grpc.CallOption) (*MSTRoundStepResponse, error)
}

MSTManagerServiceClient is the client API for MSTManagerService service.

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

type MSTManagerServiceServer

type MSTManagerServiceServer interface {
	RoundStart(context.Context, *MSTRoundStartRequest) (*MSTRoundStepResponse, error)
	RoundStep(context.Context, *MSTRoundStepRequest) (*MSTRoundStepResponse, error)
}

MSTManagerServiceServer is the server API for MSTManagerService service.

type MSTNode

type MSTNode struct {
	Level    uint32      `protobuf:"varint,1,opt,name=level,proto3" json:"level,omitempty"`
	Low      []byte      `protobuf:"bytes,2,opt,name=low,proto3" json:"low,omitempty"`
	Children []*MSTChild `protobuf:"bytes,3,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTNode) Descriptor deprecated

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

Deprecated: Use MSTNode.ProtoReflect.Descriptor instead.

func (*MSTNode) GetChildren

func (x *MSTNode) GetChildren() []*MSTChild

func (*MSTNode) GetLevel

func (x *MSTNode) GetLevel() uint32

func (*MSTNode) GetLow

func (x *MSTNode) GetLow() []byte

func (*MSTNode) ProtoMessage

func (*MSTNode) ProtoMessage()

func (*MSTNode) ProtoReflect

func (x *MSTNode) ProtoReflect() protoreflect.Message

func (*MSTNode) Reset

func (x *MSTNode) Reset()

func (*MSTNode) String

func (x *MSTNode) String() string

type MSTPutRequest

type MSTPutRequest struct {
	Key   uint32 `protobuf:"varint,1,opt,name=key,proto3" json:"key,omitempty"`
	Value uint32 `protobuf:"varint,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTPutRequest) Descriptor deprecated

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

Deprecated: Use MSTPutRequest.ProtoReflect.Descriptor instead.

func (*MSTPutRequest) GetKey

func (x *MSTPutRequest) GetKey() uint32

func (*MSTPutRequest) GetValue

func (x *MSTPutRequest) GetValue() uint32

func (*MSTPutRequest) ProtoMessage

func (*MSTPutRequest) ProtoMessage()

func (*MSTPutRequest) ProtoReflect

func (x *MSTPutRequest) ProtoReflect() protoreflect.Message

func (*MSTPutRequest) Reset

func (x *MSTPutRequest) Reset()

func (*MSTPutRequest) String

func (x *MSTPutRequest) String() string

type MSTRoundStartRequest

type MSTRoundStartRequest struct {
	RoundUuid []byte `protobuf:"bytes,1,opt,name=round_uuid,json=roundUuid,proto3" json:"round_uuid,omitempty"`
	RootHash  []byte `protobuf:"bytes,2,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTRoundStartRequest) Descriptor deprecated

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

Deprecated: Use MSTRoundStartRequest.ProtoReflect.Descriptor instead.

func (*MSTRoundStartRequest) GetRootHash

func (x *MSTRoundStartRequest) GetRootHash() []byte

func (*MSTRoundStartRequest) GetRoundUuid

func (x *MSTRoundStartRequest) GetRoundUuid() []byte

func (*MSTRoundStartRequest) ProtoMessage

func (*MSTRoundStartRequest) ProtoMessage()

func (*MSTRoundStartRequest) ProtoReflect

func (x *MSTRoundStartRequest) ProtoReflect() protoreflect.Message

func (*MSTRoundStartRequest) Reset

func (x *MSTRoundStartRequest) Reset()

func (*MSTRoundStartRequest) String

func (x *MSTRoundStartRequest) String() string

type MSTRoundStepRequest

type MSTRoundStepRequest struct {
	RoundUuid []byte     `protobuf:"bytes,1,opt,name=round_uuid,json=roundUuid,proto3" json:"round_uuid,omitempty"`
	Nodes     []*MSTNode `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTRoundStepRequest) Descriptor deprecated

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

Deprecated: Use MSTRoundStepRequest.ProtoReflect.Descriptor instead.

func (*MSTRoundStepRequest) GetNodes

func (x *MSTRoundStepRequest) GetNodes() []*MSTNode

func (*MSTRoundStepRequest) GetRoundUuid

func (x *MSTRoundStepRequest) GetRoundUuid() []byte

func (*MSTRoundStepRequest) ProtoMessage

func (*MSTRoundStepRequest) ProtoMessage()

func (*MSTRoundStepRequest) ProtoReflect

func (x *MSTRoundStepRequest) ProtoReflect() protoreflect.Message

func (*MSTRoundStepRequest) Reset

func (x *MSTRoundStepRequest) Reset()

func (*MSTRoundStepRequest) String

func (x *MSTRoundStepRequest) String() string

type MSTRoundStepResponse

type MSTRoundStepResponse struct {
	Hashes [][]byte `protobuf:"bytes,1,rep,name=hashes,proto3" json:"hashes,omitempty"`
	// contains filtered or unexported fields
}

func (*MSTRoundStepResponse) Descriptor deprecated

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

Deprecated: Use MSTRoundStepResponse.ProtoReflect.Descriptor instead.

func (*MSTRoundStepResponse) GetHashes

func (x *MSTRoundStepResponse) GetHashes() [][]byte

func (*MSTRoundStepResponse) ProtoMessage

func (*MSTRoundStepResponse) ProtoMessage()

func (*MSTRoundStepResponse) ProtoReflect

func (x *MSTRoundStepResponse) ProtoReflect() protoreflect.Message

func (*MSTRoundStepResponse) Reset

func (x *MSTRoundStepResponse) Reset()

func (*MSTRoundStepResponse) String

func (x *MSTRoundStepResponse) String() string

type MSTServiceClient

type MSTServiceClient interface {
	Put(ctx context.Context, in *MSTPutRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Get(ctx context.Context, in *MSTGetRequest, opts ...grpc.CallOption) (*MSTGetResponse, error)
}

MSTServiceClient is the client API for MSTService service.

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

func NewMSTServiceClient

func NewMSTServiceClient(cc grpc.ClientConnInterface) MSTServiceClient

type MSTServiceServer

type MSTServiceServer interface {
	Put(context.Context, *MSTPutRequest) (*empty.Empty, error)
	Get(context.Context, *MSTGetRequest) (*MSTGetResponse, error)
}

MSTServiceServer is the server API for MSTService service.

type UnimplementedMSTManagerServiceServer

type UnimplementedMSTManagerServiceServer struct {
}

UnimplementedMSTManagerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMSTManagerServiceServer) RoundStart

func (*UnimplementedMSTManagerServiceServer) RoundStep

type UnimplementedMSTServiceServer

type UnimplementedMSTServiceServer struct {
}

UnimplementedMSTServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMSTServiceServer) Get

func (*UnimplementedMSTServiceServer) Put

Source Files

Jump to

Keyboard shortcuts

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