server

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterXRDServer 

func RegisterXRDServer(s *grpc.Server, srv XRDServer)

Types

type EndRoundRequest 

type EndRoundRequest struct {
	Round                uint64   `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndRoundRequest) Descriptor 

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

func (*EndRoundRequest) GetRound 

func (m *EndRoundRequest) GetRound() uint64

func (*EndRoundRequest) ProtoMessage 

func (*EndRoundRequest) ProtoMessage()

func (*EndRoundRequest) Reset 

func (m *EndRoundRequest) Reset()

func (*EndRoundRequest) String 

func (m *EndRoundRequest) String() string

func (*EndRoundRequest) XXX_DiscardUnknown 

func (m *EndRoundRequest) XXX_DiscardUnknown()

func (*EndRoundRequest) XXX_Marshal 

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

func (*EndRoundRequest) XXX_Merge 

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

func (*EndRoundRequest) XXX_Size 

func (m *EndRoundRequest) XXX_Size() int

func (*EndRoundRequest) XXX_Unmarshal 

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

type EndRoundResponse 

type EndRoundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EndRoundResponse) Descriptor 

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

func (*EndRoundResponse) ProtoMessage 

func (*EndRoundResponse) ProtoMessage()

func (*EndRoundResponse) Reset 

func (m *EndRoundResponse) Reset()

func (*EndRoundResponse) String 

func (m *EndRoundResponse) String() string

func (*EndRoundResponse) XXX_DiscardUnknown 

func (m *EndRoundResponse) XXX_DiscardUnknown()

func (*EndRoundResponse) XXX_Marshal 

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

func (*EndRoundResponse) XXX_Merge 

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

func (*EndRoundResponse) XXX_Size 

func (m *EndRoundResponse) XXX_Size() int

func (*EndRoundResponse) XXX_Unmarshal 

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

type NewRoundRequest 

type NewRoundRequest struct {
	Round                uint64   `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewRoundRequest) Descriptor 

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

func (*NewRoundRequest) GetRound 

func (m *NewRoundRequest) GetRound() uint64

func (*NewRoundRequest) ProtoMessage 

func (*NewRoundRequest) ProtoMessage()

func (*NewRoundRequest) Reset 

func (m *NewRoundRequest) Reset()

func (*NewRoundRequest) String 

func (m *NewRoundRequest) String() string

func (*NewRoundRequest) XXX_DiscardUnknown 

func (m *NewRoundRequest) XXX_DiscardUnknown()

func (*NewRoundRequest) XXX_Marshal 

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

func (*NewRoundRequest) XXX_Merge 

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

func (*NewRoundRequest) XXX_Size 

func (m *NewRoundRequest) XXX_Size() int

func (*NewRoundRequest) XXX_Unmarshal 

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

type NewRoundResponse 

type NewRoundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NewRoundResponse) Descriptor 

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

func (*NewRoundResponse) ProtoMessage 

func (*NewRoundResponse) ProtoMessage()

func (*NewRoundResponse) Reset 

func (m *NewRoundResponse) Reset()

func (*NewRoundResponse) String 

func (m *NewRoundResponse) String() string

func (*NewRoundResponse) XXX_DiscardUnknown 

func (m *NewRoundResponse) XXX_DiscardUnknown()

func (*NewRoundResponse) XXX_Marshal 

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

func (*NewRoundResponse) XXX_Merge 

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

func (*NewRoundResponse) XXX_Size 

func (m *NewRoundResponse) XXX_Size() int

func (*NewRoundResponse) XXX_Unmarshal 

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

type StartRoundRequest 

type StartRoundRequest struct {
	Round                uint64   `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartRoundRequest) Descriptor 

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

func (*StartRoundRequest) GetRound 

func (m *StartRoundRequest) GetRound() uint64

func (*StartRoundRequest) ProtoMessage 

func (*StartRoundRequest) ProtoMessage()

func (*StartRoundRequest) Reset 

func (m *StartRoundRequest) Reset()

func (*StartRoundRequest) String 

func (m *StartRoundRequest) String() string

func (*StartRoundRequest) XXX_DiscardUnknown 

func (m *StartRoundRequest) XXX_DiscardUnknown()

func (*StartRoundRequest) XXX_Marshal 

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

func (*StartRoundRequest) XXX_Merge 

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

func (*StartRoundRequest) XXX_Size 

func (m *StartRoundRequest) XXX_Size() int

func (*StartRoundRequest) XXX_Unmarshal 

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

type StartRoundResponse 

type StartRoundResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartRoundResponse) Descriptor 

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

func (*StartRoundResponse) ProtoMessage 

func (*StartRoundResponse) ProtoMessage()

func (*StartRoundResponse) Reset 

func (m *StartRoundResponse) Reset()

func (*StartRoundResponse) String 

func (m *StartRoundResponse) String() string

func (*StartRoundResponse) XXX_DiscardUnknown 

func (m *StartRoundResponse) XXX_DiscardUnknown()

func (*StartRoundResponse) XXX_Marshal 

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

func (*StartRoundResponse) XXX_Merge 

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

func (*StartRoundResponse) XXX_Size 

func (m *StartRoundResponse) XXX_Size() int

func (*StartRoundResponse) XXX_Unmarshal 

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

type UnimplementedXRDServer 

type UnimplementedXRDServer struct {
}

UnimplementedXRDServer can be embedded to have forward compatible implementations.

func (*UnimplementedXRDServer) EndRound 

func (*UnimplementedXRDServer) EndRound(ctx context.Context, req *EndRoundRequest) (*EndRoundResponse, error)

func (*UnimplementedXRDServer) NewRound 

func (*UnimplementedXRDServer) NewRound(ctx context.Context, req *NewRoundRequest) (*NewRoundResponse, error)

func (*UnimplementedXRDServer) StartRound 

func (*UnimplementedXRDServer) StartRound(ctx context.Context, req *StartRoundRequest) (*StartRoundResponse, error)

type XRDClient 

type XRDClient interface {
	NewRound(ctx context.Context, in *NewRoundRequest, opts ...grpc.CallOption) (*NewRoundResponse, error)
	EndRound(ctx context.Context, in *EndRoundRequest, opts ...grpc.CallOption) (*EndRoundResponse, error)
	StartRound(ctx context.Context, in *StartRoundRequest, opts ...grpc.CallOption) (*StartRoundResponse, error)
}

XRDClient is the client API for XRD service.

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

func NewXRDClient 

func NewXRDClient(cc *grpc.ClientConn) XRDClient

type XRDServer 

type XRDServer interface {
	NewRound(context.Context, *NewRoundRequest) (*NewRoundResponse, error)
	EndRound(context.Context, *EndRoundRequest) (*EndRoundResponse, error)
	StartRound(context.Context, *StartRoundRequest) (*StartRoundResponse, error)
}

XRDServer is the server API for XRD service.

func NewServer 

func NewServer(addr string, coordinator ecdsa.PublicKey, mailboxes, servers map[string]*config.Server, groups map[string]*config.Group, mix mixnet.MixServer) XRDServer

addr: the physical address of this server coordinator: the public key of the coordinator server servers: map (list) of all server configurations groups: map (list) of all group configurations mailboxes: map (list) of all mailboxes

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.