grpc

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 13, 2019 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthRaft = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowRaft   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterRaftServer 

func RegisterRaftServer(s *grpc.Server, srv RaftServer)

Types

type Empty 

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

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

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

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

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

func (*Empty) XXX_DiscardUnknown added in v0.2.0 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal added in v0.2.0 

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

func (*Empty) XXX_Merge added in v0.2.0 

func (dst *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size added in v0.2.0 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal added in v0.2.0 

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

type Entry 

type Entry struct {
	Index                uint64   `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Entry) Descriptor 

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

func (*Entry) GetData 

func (m *Entry) GetData() []byte

func (*Entry) GetIndex 

func (m *Entry) GetIndex() uint64

func (*Entry) Marshal 

func (m *Entry) Marshal() (dAtA []byte, err error)

func (*Entry) MarshalTo 

func (m *Entry) MarshalTo(dAtA []byte) (int, error)

func (*Entry) ProtoMessage 

func (*Entry) ProtoMessage()

func (*Entry) Reset 

func (m *Entry) Reset()

func (*Entry) Size 

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

func (*Entry) String 

func (m *Entry) String() string

func (*Entry) Unmarshal 

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

func (*Entry) XXX_DiscardUnknown added in v0.2.0 

func (m *Entry) XXX_DiscardUnknown()

func (*Entry) XXX_Marshal added in v0.2.0 

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

func (*Entry) XXX_Merge added in v0.2.0 

func (dst *Entry) XXX_Merge(src proto.Message)

func (*Entry) XXX_Size added in v0.2.0 

func (m *Entry) XXX_Size() int

func (*Entry) XXX_Unmarshal added in v0.2.0 

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

type Peer 

type Peer struct {
	Id                   uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Address              []byte   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Peer) Descriptor 

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

func (*Peer) GetAddress 

func (m *Peer) GetAddress() []byte

func (*Peer) GetId 

func (m *Peer) GetId() uint64

func (*Peer) Marshal 

func (m *Peer) Marshal() (dAtA []byte, err error)

func (*Peer) MarshalTo 

func (m *Peer) MarshalTo(dAtA []byte) (int, error)

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) Size 

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

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) Unmarshal 

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

func (*Peer) XXX_DiscardUnknown added in v0.2.0 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal added in v0.2.0 

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

func (*Peer) XXX_Merge added in v0.2.0 

func (dst *Peer) XXX_Merge(src proto.Message)

func (*Peer) XXX_Size added in v0.2.0 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal added in v0.2.0 

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

type PeerID 

type PeerID struct {
	Address              []byte   `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PeerID) Descriptor 

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

func (*PeerID) GetAddress 

func (m *PeerID) GetAddress() []byte

func (*PeerID) Marshal 

func (m *PeerID) Marshal() (dAtA []byte, err error)

func (*PeerID) MarshalTo 

func (m *PeerID) MarshalTo(dAtA []byte) (int, error)

func (*PeerID) ProtoMessage 

func (*PeerID) ProtoMessage()

func (*PeerID) Reset 

func (m *PeerID) Reset()

func (*PeerID) Size 

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

func (*PeerID) String 

func (m *PeerID) String() string

func (*PeerID) Unmarshal 

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

func (*PeerID) XXX_DiscardUnknown added in v0.2.0 

func (m *PeerID) XXX_DiscardUnknown()

func (*PeerID) XXX_Marshal added in v0.2.0 

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

func (*PeerID) XXX_Merge added in v0.2.0 

func (dst *PeerID) XXX_Merge(src proto.Message)

func (*PeerID) XXX_Size added in v0.2.0 

func (m *PeerID) XXX_Size() int

func (*PeerID) XXX_Unmarshal added in v0.2.0 

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

type Proposal 

type Proposal struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Proposal) Descriptor 

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

func (*Proposal) GetData 

func (m *Proposal) GetData() []byte

func (*Proposal) Marshal 

func (m *Proposal) Marshal() (dAtA []byte, err error)

func (*Proposal) MarshalTo 

func (m *Proposal) MarshalTo(dAtA []byte) (int, error)

func (*Proposal) ProtoMessage 

func (*Proposal) ProtoMessage()

func (*Proposal) Reset 

func (m *Proposal) Reset()

func (*Proposal) Size 

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

func (*Proposal) String 

func (m *Proposal) String() string

func (*Proposal) Unmarshal 

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

func (*Proposal) XXX_DiscardUnknown added in v0.2.0 

func (m *Proposal) XXX_DiscardUnknown()

func (*Proposal) XXX_Marshal added in v0.2.0 

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

func (*Proposal) XXX_Merge added in v0.2.0 

func (dst *Proposal) XXX_Merge(src proto.Message)

func (*Proposal) XXX_Size added in v0.2.0 

func (m *Proposal) XXX_Size() int

func (*Proposal) XXX_Unmarshal added in v0.2.0 

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

type RaftClient 

type RaftClient interface {
	Start(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Stop(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	Status(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StatusInfo, error)
	Peers(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Raft_PeersClient, error)
	Discover(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (Raft_DiscoverClient, error)
	Invite(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (*Empty, error)
	Join(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (*Empty, error)
	Expel(ctx context.Context, in *PeerID, opts ...grpc.CallOption) (*Empty, error)
	Propose(ctx context.Context, in *Proposal, opts ...grpc.CallOption) (*Empty, error)
	Log(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Raft_LogClient, error)
}

func NewRaftClient 

func NewRaftClient(cc *grpc.ClientConn) RaftClient

type RaftServer 

type RaftServer interface {
	Start(context.Context, *Empty) (*Empty, error)
	Stop(context.Context, *Empty) (*Empty, error)
	Status(context.Context, *Empty) (*StatusInfo, error)
	Peers(*Empty, Raft_PeersServer) error
	Discover(*PeerID, Raft_DiscoverServer) error
	Invite(context.Context, *PeerID) (*Empty, error)
	Join(context.Context, *PeerID) (*Empty, error)
	Expel(context.Context, *PeerID) (*Empty, error)
	Propose(context.Context, *Proposal) (*Empty, error)
	Log(*Empty, Raft_LogServer) error
}

type Raft_DiscoverClient 

type Raft_DiscoverClient interface {
	Recv() (*Peer, error)
	grpc.ClientStream
}

type Raft_DiscoverServer 

type Raft_DiscoverServer interface {
	Send(*Peer) error
	grpc.ServerStream
}

type Raft_LogClient 

type Raft_LogClient interface {
	Recv() (*Entry, error)
	grpc.ClientStream
}

type Raft_LogServer 

type Raft_LogServer interface {
	Send(*Entry) error
	grpc.ServerStream
}

type Raft_PeersClient 

type Raft_PeersClient interface {
	Recv() (*Peer, error)
	grpc.ClientStream
}

type Raft_PeersServer 

type Raft_PeersServer interface {
	Send(*Peer) error
	grpc.ServerStream
}

type StatusInfo 

type StatusInfo struct {
	Running              bool     `protobuf:"varint,1,opt,name=running,proto3" json:"running,omitempty"`
	Id                   uint64   `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatusInfo) Descriptor 

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

func (*StatusInfo) GetId 

func (m *StatusInfo) GetId() uint64

func (*StatusInfo) GetRunning 

func (m *StatusInfo) GetRunning() bool

func (*StatusInfo) Marshal 

func (m *StatusInfo) Marshal() (dAtA []byte, err error)

func (*StatusInfo) MarshalTo 

func (m *StatusInfo) MarshalTo(dAtA []byte) (int, error)

func (*StatusInfo) ProtoMessage 

func (*StatusInfo) ProtoMessage()

func (*StatusInfo) Reset 

func (m *StatusInfo) Reset()

func (*StatusInfo) Size 

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

func (*StatusInfo) String 

func (m *StatusInfo) String() string

func (*StatusInfo) Unmarshal 

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

func (*StatusInfo) XXX_DiscardUnknown added in v0.2.0 

func (m *StatusInfo) XXX_DiscardUnknown()

func (*StatusInfo) XXX_Marshal added in v0.2.0 

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

func (*StatusInfo) XXX_Merge added in v0.2.0 

func (dst *StatusInfo) XXX_Merge(src proto.Message)

func (*StatusInfo) XXX_Size added in v0.2.0 

func (m *StatusInfo) XXX_Size() int

func (*StatusInfo) XXX_Unmarshal added in v0.2.0 

func (m *StatusInfo) XXX_Unmarshal(b []byte) 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.