Documentation ¶
Overview ¶
Package node is a generated GoMock package.
Index ¶
- Variables
- func DecodePrivateKey(keyHex string) (crypto.PrivKey, error)
- func GeneratePrivateKey() (crypto.PrivKey, error)
- func PrivateKeyToHex(key crypto.PrivKey) (string, error)
- type Metrics
- type MockMessageApi_SubscribeServer
- func (m *MockMessageApi_SubscribeServer) Context() context.Context
- func (m *MockMessageApi_SubscribeServer) EXPECT() *MockMessageApi_SubscribeServerMockRecorder
- func (m *MockMessageApi_SubscribeServer) RecvMsg(arg0 interface{}) error
- func (m *MockMessageApi_SubscribeServer) Send(arg0 *v1.Envelope) error
- func (m *MockMessageApi_SubscribeServer) SendHeader(arg0 metadata.MD) error
- func (m *MockMessageApi_SubscribeServer) SendMsg(arg0 interface{}) error
- func (m *MockMessageApi_SubscribeServer) SetHeader(arg0 metadata.MD) error
- func (m *MockMessageApi_SubscribeServer) SetTrailer(arg0 metadata.MD)
- type MockMessageApi_SubscribeServerMockRecorder
- func (mr *MockMessageApi_SubscribeServerMockRecorder) Context() *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
- func (mr *MockMessageApi_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
- type Node
- func (n *Node) APIHTTPListenPort() uint
- func (n *Node) Address() peer.AddrInfo
- func (n *Node) BatchQuery(gctx gocontext.Context, req *messagev1.BatchQueryRequest) (*messagev1.BatchQueryResponse, error)
- func (n *Node) Close()
- func (n *Node) Connect(ctx context.Context, addr peer.AddrInfo) error
- func (n *Node) ConnectedPeers() map[peer.ID]*peer.AddrInfo
- func (n *Node) DeleteTopic(topic string) error
- func (n *Node) Disconnect(ctx context.Context, peer peer.ID) error
- func (n *Node) ID() peer.ID
- func (n *Node) P2PListenAddresses() []string
- func (n *Node) PubSubPeers() []peer.ID
- func (n *Node) Publish(gctx gocontext.Context, req *messagev1.PublishRequest) (*messagev1.PublishResponse, error)
- func (n *Node) Query(gctx gocontext.Context, req *messagev1.QueryRequest) (*messagev1.QueryResponse, error)
- func (n *Node) Subscribe(req *messagev1.SubscribeRequest, stream messagev1.MessageApi_SubscribeServer) error
- func (n *Node) SubscribeAll(req *messagev1.SubscribeAllRequest, ...) error
- type NodeStore
- type Options
- type P2POptions
- type StoreOptions
Constants ¶
This section is empty.
Variables ¶
var ( ErrUnknownTopic = errors.New("topic does not exist") ErrMissingTopic = errors.New("missing topic") ErrTooManyTopics = errors.New("too many topics") ErrTopicAlreadyExists = errors.New("topic already exists") )
var (
ErrNoSyncPeer = errors.New("no peer to sync with")
)
Functions ¶
func GeneratePrivateKey ¶
Types ¶
type Metrics ¶
type Metrics struct { API *gateway.Metrics Replicas *crdt.Metrics // contains filtered or unexported fields }
func NewMetrics ¶
func NewMetrics() *Metrics
type MockMessageApi_SubscribeServer ¶
type MockMessageApi_SubscribeServer struct {
// contains filtered or unexported fields
}
MockMessageApi_SubscribeServer is a mock of MessageApi_SubscribeServer interface.
func NewMockMessageApi_SubscribeServer ¶
func NewMockMessageApi_SubscribeServer(ctrl *gomock.Controller) *MockMessageApi_SubscribeServer
NewMockMessageApi_SubscribeServer creates a new mock instance.
func (*MockMessageApi_SubscribeServer) Context ¶
func (m *MockMessageApi_SubscribeServer) Context() context.Context
Context mocks base method.
func (*MockMessageApi_SubscribeServer) EXPECT ¶
func (m *MockMessageApi_SubscribeServer) EXPECT() *MockMessageApi_SubscribeServerMockRecorder
EXPECT returns an object that allows the caller to indicate expected use.
func (*MockMessageApi_SubscribeServer) RecvMsg ¶
func (m *MockMessageApi_SubscribeServer) RecvMsg(arg0 interface{}) error
RecvMsg mocks base method.
func (*MockMessageApi_SubscribeServer) Send ¶
func (m *MockMessageApi_SubscribeServer) Send(arg0 *v1.Envelope) error
Send mocks base method.
func (*MockMessageApi_SubscribeServer) SendHeader ¶
func (m *MockMessageApi_SubscribeServer) SendHeader(arg0 metadata.MD) error
SendHeader mocks base method.
func (*MockMessageApi_SubscribeServer) SendMsg ¶
func (m *MockMessageApi_SubscribeServer) SendMsg(arg0 interface{}) error
SendMsg mocks base method.
func (*MockMessageApi_SubscribeServer) SetHeader ¶
func (m *MockMessageApi_SubscribeServer) SetHeader(arg0 metadata.MD) error
SetHeader mocks base method.
func (*MockMessageApi_SubscribeServer) SetTrailer ¶
func (m *MockMessageApi_SubscribeServer) SetTrailer(arg0 metadata.MD)
SetTrailer mocks base method.
type MockMessageApi_SubscribeServerMockRecorder ¶
type MockMessageApi_SubscribeServerMockRecorder struct {
// contains filtered or unexported fields
}
MockMessageApi_SubscribeServerMockRecorder is the mock recorder for MockMessageApi_SubscribeServer.
func (*MockMessageApi_SubscribeServerMockRecorder) Context ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) Context() *gomock.Call
Context indicates an expected call of Context.
func (*MockMessageApi_SubscribeServerMockRecorder) RecvMsg ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) RecvMsg(arg0 interface{}) *gomock.Call
RecvMsg indicates an expected call of RecvMsg.
func (*MockMessageApi_SubscribeServerMockRecorder) Send ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) Send(arg0 interface{}) *gomock.Call
Send indicates an expected call of Send.
func (*MockMessageApi_SubscribeServerMockRecorder) SendHeader ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call
SendHeader indicates an expected call of SendHeader.
func (*MockMessageApi_SubscribeServerMockRecorder) SendMsg ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) SendMsg(arg0 interface{}) *gomock.Call
SendMsg indicates an expected call of SendMsg.
func (*MockMessageApi_SubscribeServerMockRecorder) SetHeader ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call
SetHeader indicates an expected call of SetHeader.
func (*MockMessageApi_SubscribeServerMockRecorder) SetTrailer ¶
func (mr *MockMessageApi_SubscribeServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call
SetTrailer indicates an expected call of SetTrailer.
type Node ¶
type Node struct { messagev1.UnimplementedMessageApiServer // contains filtered or unexported fields }
func (*Node) APIHTTPListenPort ¶
func (*Node) BatchQuery ¶
func (n *Node) BatchQuery(gctx gocontext.Context, req *messagev1.BatchQueryRequest) (*messagev1.BatchQueryResponse, error)
func (*Node) DeleteTopic ¶
func (*Node) P2PListenAddresses ¶
func (*Node) PubSubPeers ¶
func (*Node) Publish ¶
func (n *Node) Publish(gctx gocontext.Context, req *messagev1.PublishRequest) (*messagev1.PublishResponse, error)
func (*Node) Query ¶
func (n *Node) Query(gctx gocontext.Context, req *messagev1.QueryRequest) (*messagev1.QueryResponse, error)
func (*Node) Subscribe ¶
func (n *Node) Subscribe(req *messagev1.SubscribeRequest, stream messagev1.MessageApi_SubscribeServer) error
func (*Node) SubscribeAll ¶
func (n *Node) SubscribeAll(req *messagev1.SubscribeAllRequest, stream messagev1.MessageApi_SubscribeAllServer) error
type NodeStore ¶
type NodeStore interface { // Open or create a topic store in the node store NewTopic(topic string) (crdt.Store, error) // Return list of names for all topic stores in the node store Topics() ([]string, error) // Close the node store Close() error // Remove topic from the store. // Assumes the replica for the topic has been closed. DeleteTopic(topic string) error }
type Options ¶
type Options struct { Log zap.Options `group:"Log options" namespace:"log"` P2P P2POptions `group:"P2P options" namespace:"p2p"` API apigateway.Options `group:"API options" namespace:"api"` Store StoreOptions `group:"Store options" namespace:"store"` TopicReaperPeriod time.Duration `long:"topic-reaper-period" description:"delete invalid and test topics after this duration"` }
type P2POptions ¶
type StoreOptions ¶
type StoreOptions struct { Type string `long:"type" description:"type of storage to use" choice:"mem" choice:"postgres" choice:"bolt" default:"mem"` Postgres postgresstore.Options `group:"Store Postgres options" namespace:"postgres"` Bolt bolt.Options `group:"Store Bolt options" namespace:"bolt"` }