fairnode

Documentation

Index

• func RegisterFairnodeServiceServer(s *grpc.Server, srv FairnodeServiceServer)
• func RegisterFairnodeSyncServiceServer(s *grpc.Server, srv FairnodeSyncServiceServer)
• type FairnodeServiceClient
  • func NewFairnodeServiceClient(cc *grpc.ClientConn) FairnodeServiceClient
• type FairnodeServiceServer
• type FairnodeService_ProcessControllerClient
• type FairnodeService_ProcessControllerServer
• type FairnodeService_SealConfirmClient
• type FairnodeService_SealConfirmServer
• type FairnodeSyncServiceClient
  • func NewFairnodeSyncServiceClient(cc *grpc.ClientConn) FairnodeSyncServiceClient
• type FairnodeSyncServiceServer
• type FairnodeSyncService_SyncControllerClient
• type FairnodeSyncService_SyncControllerServer
• type UnimplementedFairnodeServiceServer
  • func (*UnimplementedFairnodeServiceServer) HeartBeat(ctx context.Context, req *common.HeartBeat) (*empty.Empty, error)
  • func (*UnimplementedFairnodeServiceServer) ProcessController(req *common.Participate, srv FairnodeService_ProcessControllerServer) error
  • func (*UnimplementedFairnodeServiceServer) RequestFairnodeSign(ctx context.Context, req *common.ReqFairnodeSign) (*common.ResFairnodeSign, error)
  • func (*UnimplementedFairnodeServiceServer) RequestLeague(ctx context.Context, req *common.ReqLeague) (*common.ResLeague, error)
  • func (*UnimplementedFairnodeServiceServer) RequestOtprn(ctx context.Context, req *common.ReqOtprn) (*common.ResOtprn, error)
  • func (*UnimplementedFairnodeServiceServer) RequestVoteResult(ctx context.Context, req *common.ReqVoteResult) (*common.ResVoteResult, error)
  • func (*UnimplementedFairnodeServiceServer) SealConfirm(req *common.ReqConfirmSeal, srv FairnodeService_SealConfirmServer) error
  • func (*UnimplementedFairnodeServiceServer) SendBlock(ctx context.Context, req *common.ReqBlock) (*empty.Empty, error)
  • func (*UnimplementedFairnodeServiceServer) Vote(ctx context.Context, req *common.Vote) (*empty.Empty, error)
• type UnimplementedFairnodeSyncServiceServer
  • func (*UnimplementedFairnodeSyncServiceServer) SyncController(req *empty.Empty, srv FairnodeSyncService_SyncControllerServer) error

Functions

func RegisterFairnodeServiceServer

func RegisterFairnodeServiceServer(s *grpc.Server, srv FairnodeServiceServer)

func RegisterFairnodeSyncServiceServer

func RegisterFairnodeSyncServiceServer(s *grpc.Server, srv FairnodeSyncServiceServer)

Types

type FairnodeServiceClient

type FairnodeServiceClient interface {
	HeartBeat(ctx context.Context, in *common.HeartBeat, opts ...grpc.CallOption) (*empty.Empty, error)
	RequestOtprn(ctx context.Context, in *common.ReqOtprn, opts ...grpc.CallOption) (*common.ResOtprn, error)
	ProcessController(ctx context.Context, in *common.Participate, opts ...grpc.CallOption) (FairnodeService_ProcessControllerClient, error)
	RequestLeague(ctx context.Context, in *common.ReqLeague, opts ...grpc.CallOption) (*common.ResLeague, error)
	Vote(ctx context.Context, in *common.Vote, opts ...grpc.CallOption) (*empty.Empty, error)
	RequestVoteResult(ctx context.Context, in *common.ReqVoteResult, opts ...grpc.CallOption) (*common.ResVoteResult, error)
	SealConfirm(ctx context.Context, in *common.ReqConfirmSeal, opts ...grpc.CallOption) (FairnodeService_SealConfirmClient, error)
	SendBlock(ctx context.Context, in *common.ReqBlock, opts ...grpc.CallOption) (*empty.Empty, error)
	RequestFairnodeSign(ctx context.Context, in *common.ReqFairnodeSign, opts ...grpc.CallOption) (*common.ResFairnodeSign, error)
}

FairnodeServiceClient is the client API for FairnodeService service.

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

func NewFairnodeServiceClient

func NewFairnodeServiceClient(cc *grpc.ClientConn) FairnodeServiceClient

type FairnodeServiceServer

type FairnodeServiceServer interface {
	HeartBeat(context.Context, *common.HeartBeat) (*empty.Empty, error)
	RequestOtprn(context.Context, *common.ReqOtprn) (*common.ResOtprn, error)
	ProcessController(*common.Participate, FairnodeService_ProcessControllerServer) error
	RequestLeague(context.Context, *common.ReqLeague) (*common.ResLeague, error)
	Vote(context.Context, *common.Vote) (*empty.Empty, error)
	RequestVoteResult(context.Context, *common.ReqVoteResult) (*common.ResVoteResult, error)
	SealConfirm(*common.ReqConfirmSeal, FairnodeService_SealConfirmServer) error
	SendBlock(context.Context, *common.ReqBlock) (*empty.Empty, error)
	RequestFairnodeSign(context.Context, *common.ReqFairnodeSign) (*common.ResFairnodeSign, error)
}

FairnodeServiceServer is the server API for FairnodeService service.

type FairnodeService_ProcessControllerClient

type FairnodeService_ProcessControllerClient interface {
	Recv() (*common.ProcessMessage, error)
	grpc.ClientStream
}

type FairnodeService_ProcessControllerServer

type FairnodeService_ProcessControllerServer interface {
	Send(*common.ProcessMessage) error
	grpc.ServerStream
}

type FairnodeService_SealConfirmClient

type FairnodeService_SealConfirmClient interface {
	Recv() (*common.ResConfirmSeal, error)
	grpc.ClientStream
}

type FairnodeService_SealConfirmServer

type FairnodeService_SealConfirmServer interface {
	Send(*common.ResConfirmSeal) error
	grpc.ServerStream
}

type FairnodeSyncServiceClient

type FairnodeSyncServiceClient interface {
	SyncController(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (FairnodeSyncService_SyncControllerClient, error)
}

FairnodeSyncServiceClient is the client API for FairnodeSyncService service.

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

func NewFairnodeSyncServiceClient

func NewFairnodeSyncServiceClient(cc *grpc.ClientConn) FairnodeSyncServiceClient

type FairnodeSyncServiceServer

type FairnodeSyncServiceServer interface {
	SyncController(*empty.Empty, FairnodeSyncService_SyncControllerServer) error
}

FairnodeSyncServiceServer is the server API for FairnodeSyncService service.

type FairnodeSyncService_SyncControllerClient

type FairnodeSyncService_SyncControllerClient interface {
	Recv() (*common.FairnodeMessage, error)
	grpc.ClientStream
}

type FairnodeSyncService_SyncControllerServer

type FairnodeSyncService_SyncControllerServer interface {
	Send(*common.FairnodeMessage) error
	grpc.ServerStream
}

type UnimplementedFairnodeServiceServer

type UnimplementedFairnodeServiceServer struct {
}

UnimplementedFairnodeServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFairnodeServiceServer) HeartBeat

func (*UnimplementedFairnodeServiceServer) HeartBeat(ctx context.Context, req *common.HeartBeat) (*empty.Empty, error)

func (*UnimplementedFairnodeServiceServer) ProcessController

func (*UnimplementedFairnodeServiceServer) ProcessController(req *common.Participate, srv FairnodeService_ProcessControllerServer) error

func (*UnimplementedFairnodeServiceServer) RequestFairnodeSign

func (*UnimplementedFairnodeServiceServer) RequestFairnodeSign(ctx context.Context, req *common.ReqFairnodeSign) (*common.ResFairnodeSign, error)

func (*UnimplementedFairnodeServiceServer) RequestLeague

func (*UnimplementedFairnodeServiceServer) RequestLeague(ctx context.Context, req *common.ReqLeague) (*common.ResLeague, error)

func (*UnimplementedFairnodeServiceServer) RequestOtprn

func (*UnimplementedFairnodeServiceServer) RequestOtprn(ctx context.Context, req *common.ReqOtprn) (*common.ResOtprn, error)

func (*UnimplementedFairnodeServiceServer) RequestVoteResult

func (*UnimplementedFairnodeServiceServer) RequestVoteResult(ctx context.Context, req *common.ReqVoteResult) (*common.ResVoteResult, error)

func (*UnimplementedFairnodeServiceServer) SealConfirm

func (*UnimplementedFairnodeServiceServer) SealConfirm(req *common.ReqConfirmSeal, srv FairnodeService_SealConfirmServer) error

func (*UnimplementedFairnodeServiceServer) SendBlock

func (*UnimplementedFairnodeServiceServer) SendBlock(ctx context.Context, req *common.ReqBlock) (*empty.Empty, error)

func (*UnimplementedFairnodeServiceServer) Vote

func (*UnimplementedFairnodeServiceServer) Vote(ctx context.Context, req *common.Vote) (*empty.Empty, error)

type UnimplementedFairnodeSyncServiceServer

type UnimplementedFairnodeSyncServiceServer struct {
}

UnimplementedFairnodeSyncServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedFairnodeSyncServiceServer) SyncController

func (*UnimplementedFairnodeSyncServiceServer) SyncController(req *empty.Empty, srv FairnodeSyncService_SyncControllerServer) error