bertydemo

Apr 2, 2020

Changes in this version

type Client

+ func NewClient(svc *Service) (Client, error)

+ func NewClientFromServer(s *grpc.Server, svc *Service) (Client, error)

Mar 31, 2020

Changes in this version

+ type Service struct

+ func (s *Service) Close() error

+ func (s *Service) LogAdd(ctx context.Context, req *LogAdd_Request) (*LogAdd_Reply, error)

+ func (s *Service) LogGet(ctx context.Context, req *LogGet_Request) (*LogGet_Reply, error)

+ func (s *Service) LogList(ctx context.Context, req *LogList_Request) (*LogList_Reply, error)

+ func (s *Service) LogStream(req *LogStream_Request, srv DemoService_LogStreamServer) error

+ func (s *Service) LogToken(ctx context.Context, _ *LogToken_Request) (*LogToken_Reply, error)

Mar 26, 2020

Changes in this version

+ func RegisterDemoServiceServer(s *grpc.Server, srv DemoServiceServer)

+ type Client struct

+ func New(opts *Opts) (*Client, error)

+ func (d *Client) Close() error

+ func (d *Client) LogAdd(ctx context.Context, req *LogAdd_Request) (*LogAdd_Reply, error)

+ func (d *Client) LogGet(ctx context.Context, req *LogGet_Request) (*LogGet_Reply, error)

+ func (d *Client) LogList(ctx context.Context, req *LogList_Request) (*LogList_Reply, error)

+ func (d *Client) LogStream(req *LogStream_Request, srv DemoService_LogStreamServer) error

+ func (d *Client) LogToken(ctx context.Context, _ *LogToken_Request) (*LogToken_Reply, error)

+ type DemoServiceClient interface

+ LogAdd func(ctx context.Context, in *LogAdd_Request, opts ...grpc.CallOption) (*LogAdd_Reply, error)

+ LogGet func(ctx context.Context, in *LogGet_Request, opts ...grpc.CallOption) (*LogGet_Reply, error)

+ LogList func(ctx context.Context, in *LogList_Request, opts ...grpc.CallOption) (*LogList_Reply, error)

+ LogStream func(ctx context.Context, in *LogStream_Request, opts ...grpc.CallOption) (DemoService_LogStreamClient, error)

+ LogToken func(ctx context.Context, in *LogToken_Request, opts ...grpc.CallOption) (*LogToken_Reply, error)

+ func NewDemoServiceClient(cc *grpc.ClientConn) DemoServiceClient

+ type DemoServiceServer interface

+ LogAdd func(context.Context, *LogAdd_Request) (*LogAdd_Reply, error)

+ LogGet func(context.Context, *LogGet_Request) (*LogGet_Reply, error)

+ LogList func(context.Context, *LogList_Request) (*LogList_Reply, error)

+ LogStream func(*LogStream_Request, DemoService_LogStreamServer) error

+ LogToken func(context.Context, *LogToken_Request) (*LogToken_Reply, error)

+ type DemoService_LogStreamClient interface

+ Recv func() (*LogOperation, error)

+ type DemoService_LogStreamServer interface

+ Send func(*LogOperation) error

+ type LogAdd struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogAdd) Descriptor() ([]byte, []int)

+ func (*LogAdd) ProtoMessage()

+ func (m *LogAdd) Reset()

+ func (m *LogAdd) String() string

+ func (m *LogAdd) XXX_DiscardUnknown()

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

+ func (m *LogAdd) XXX_Merge(src proto.Message)

+ func (m *LogAdd) XXX_Size() int

+ func (m *LogAdd) XXX_Unmarshal(b []byte) error

+ type LogAdd_Reply struct

+ Cid string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogAdd_Reply) Descriptor() ([]byte, []int)

+ func (*LogAdd_Reply) ProtoMessage()

+ func (m *LogAdd_Reply) GetCid() string

+ func (m *LogAdd_Reply) Reset()

+ func (m *LogAdd_Reply) String() string

+ func (m *LogAdd_Reply) XXX_DiscardUnknown()

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

+ func (m *LogAdd_Reply) XXX_Merge(src proto.Message)

+ func (m *LogAdd_Reply) XXX_Size() int

+ func (m *LogAdd_Reply) XXX_Unmarshal(b []byte) error

+ type LogAdd_Request struct

+ Data []byte

+ LogToken string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogAdd_Request) Descriptor() ([]byte, []int)

+ func (*LogAdd_Request) ProtoMessage()

+ func (m *LogAdd_Request) GetData() []byte

+ func (m *LogAdd_Request) GetLogToken() string

+ func (m *LogAdd_Request) Reset()

+ func (m *LogAdd_Request) String() string

+ func (m *LogAdd_Request) XXX_DiscardUnknown()

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

+ func (m *LogAdd_Request) XXX_Merge(src proto.Message)

+ func (m *LogAdd_Request) XXX_Size() int

+ func (m *LogAdd_Request) XXX_Unmarshal(b []byte) error

+ type LogGet struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogGet) Descriptor() ([]byte, []int)

+ func (*LogGet) ProtoMessage()

+ func (m *LogGet) Reset()

+ func (m *LogGet) String() string

+ func (m *LogGet) XXX_DiscardUnknown()

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

+ func (m *LogGet) XXX_Merge(src proto.Message)

+ func (m *LogGet) XXX_Size() int

+ func (m *LogGet) XXX_Unmarshal(b []byte) error

+ type LogGet_Reply struct

+ Operation *LogOperation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogGet_Reply) Descriptor() ([]byte, []int)

+ func (*LogGet_Reply) ProtoMessage()

+ func (m *LogGet_Reply) GetOperation() *LogOperation

+ func (m *LogGet_Reply) Reset()

+ func (m *LogGet_Reply) String() string

+ func (m *LogGet_Reply) XXX_DiscardUnknown()

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

+ func (m *LogGet_Reply) XXX_Merge(src proto.Message)

+ func (m *LogGet_Reply) XXX_Size() int

+ func (m *LogGet_Reply) XXX_Unmarshal(b []byte) error

+ type LogGet_Request struct

+ Cid string

+ LogToken string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogGet_Request) Descriptor() ([]byte, []int)

+ func (*LogGet_Request) ProtoMessage()

+ func (m *LogGet_Request) GetCid() string

+ func (m *LogGet_Request) GetLogToken() string

+ func (m *LogGet_Request) Reset()

+ func (m *LogGet_Request) String() string

+ func (m *LogGet_Request) XXX_DiscardUnknown()

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

+ func (m *LogGet_Request) XXX_Merge(src proto.Message)

+ func (m *LogGet_Request) XXX_Size() int

+ func (m *LogGet_Request) XXX_Unmarshal(b []byte) error

+ type LogList struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogList) Descriptor() ([]byte, []int)

+ func (*LogList) ProtoMessage()

+ func (m *LogList) Reset()

+ func (m *LogList) String() string

+ func (m *LogList) XXX_DiscardUnknown()

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

+ func (m *LogList) XXX_Merge(src proto.Message)

+ func (m *LogList) XXX_Size() int

+ func (m *LogList) XXX_Unmarshal(b []byte) error

+ type LogList_Reply struct

+ Operations []*LogOperation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogList_Reply) Descriptor() ([]byte, []int)

+ func (*LogList_Reply) ProtoMessage()

+ func (m *LogList_Reply) GetOperations() []*LogOperation

+ func (m *LogList_Reply) Reset()

+ func (m *LogList_Reply) String() string

+ func (m *LogList_Reply) XXX_DiscardUnknown()

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

+ func (m *LogList_Reply) XXX_Merge(src proto.Message)

+ func (m *LogList_Reply) XXX_Size() int

+ func (m *LogList_Reply) XXX_Unmarshal(b []byte) error

+ type LogList_Request struct

+ LogToken string

+ Options *LogStreamOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogList_Request) Descriptor() ([]byte, []int)

+ func (*LogList_Request) ProtoMessage()

+ func (m *LogList_Request) GetLogToken() string

+ func (m *LogList_Request) GetOptions() *LogStreamOptions

+ func (m *LogList_Request) Reset()

+ func (m *LogList_Request) String() string

+ func (m *LogList_Request) XXX_DiscardUnknown()

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

+ func (m *LogList_Request) XXX_Merge(src proto.Message)

+ func (m *LogList_Request) XXX_Size() int

+ func (m *LogList_Request) XXX_Unmarshal(b []byte) error

+ type LogOperation struct

+ Cid string

+ Name string

+ Value []byte

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogOperation) Descriptor() ([]byte, []int)

+ func (*LogOperation) ProtoMessage()

+ func (m *LogOperation) GetCid() string

+ func (m *LogOperation) GetName() string

+ func (m *LogOperation) GetValue() []byte

+ func (m *LogOperation) Reset()

+ func (m *LogOperation) String() string

+ func (m *LogOperation) XXX_DiscardUnknown()

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

+ func (m *LogOperation) XXX_Merge(src proto.Message)

+ func (m *LogOperation) XXX_Size() int

+ func (m *LogOperation) XXX_Unmarshal(b []byte) error

+ type LogStream struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStream) Descriptor() ([]byte, []int)

+ func (*LogStream) ProtoMessage()

+ func (m *LogStream) Reset()

+ func (m *LogStream) String() string

+ func (m *LogStream) XXX_DiscardUnknown()

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

+ func (m *LogStream) XXX_Merge(src proto.Message)

+ func (m *LogStream) XXX_Size() int

+ func (m *LogStream) XXX_Unmarshal(b []byte) error

+ type LogStreamOptions struct

+ Amount uint32

+ GT string

+ GTE string

+ LT string

+ LTE string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStreamOptions) Descriptor() ([]byte, []int)

+ func (*LogStreamOptions) ProtoMessage()

+ func (m *LogStreamOptions) GetAmount() uint32

+ func (m *LogStreamOptions) GetGT() string

+ func (m *LogStreamOptions) GetGTE() string

+ func (m *LogStreamOptions) GetLT() string

+ func (m *LogStreamOptions) GetLTE() string

+ func (m *LogStreamOptions) Reset()

+ func (m *LogStreamOptions) String() string

+ func (m *LogStreamOptions) XXX_DiscardUnknown()

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

+ func (m *LogStreamOptions) XXX_Merge(src proto.Message)

+ func (m *LogStreamOptions) XXX_Size() int

+ func (m *LogStreamOptions) XXX_Unmarshal(b []byte) error

+ type LogStream_Request struct

+ LogToken string

+ Options *LogStreamOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogStream_Request) Descriptor() ([]byte, []int)

+ func (*LogStream_Request) ProtoMessage()

+ func (m *LogStream_Request) GetLogToken() string

+ func (m *LogStream_Request) GetOptions() *LogStreamOptions

+ func (m *LogStream_Request) Reset()

+ func (m *LogStream_Request) String() string

+ func (m *LogStream_Request) XXX_DiscardUnknown()

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

+ func (m *LogStream_Request) XXX_Merge(src proto.Message)

+ func (m *LogStream_Request) XXX_Size() int

+ func (m *LogStream_Request) XXX_Unmarshal(b []byte) error

+ type LogToken struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogToken) Descriptor() ([]byte, []int)

+ func (*LogToken) ProtoMessage()

+ func (m *LogToken) Reset()

+ func (m *LogToken) String() string

+ func (m *LogToken) XXX_DiscardUnknown()

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

+ func (m *LogToken) XXX_Merge(src proto.Message)

+ func (m *LogToken) XXX_Size() int

+ func (m *LogToken) XXX_Unmarshal(b []byte) error

+ type LogToken_Reply struct

+ LogToken string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogToken_Reply) Descriptor() ([]byte, []int)

+ func (*LogToken_Reply) ProtoMessage()

+ func (m *LogToken_Reply) GetLogToken() string

+ func (m *LogToken_Reply) Reset()

+ func (m *LogToken_Reply) String() string

+ func (m *LogToken_Reply) XXX_DiscardUnknown()

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

+ func (m *LogToken_Reply) XXX_Merge(src proto.Message)

+ func (m *LogToken_Reply) XXX_Size() int

+ func (m *LogToken_Reply) XXX_Unmarshal(b []byte) error

+ type LogToken_Request struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LogToken_Request) Descriptor() ([]byte, []int)

+ func (*LogToken_Request) ProtoMessage()

+ func (m *LogToken_Request) Reset()

+ func (m *LogToken_Request) String() string

+ func (m *LogToken_Request) XXX_DiscardUnknown()

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

+ func (m *LogToken_Request) XXX_Merge(src proto.Message)

+ func (m *LogToken_Request) XXX_Size() int

+ func (m *LogToken_Request) XXX_Unmarshal(b []byte) error

+ type Opts struct

+ CoreAPI ipfs_interface.CoreAPI

+ Logger *zap.Logger

+ OrbitDBDirectory string

+ type UnimplementedDemoServiceServer struct

+ func (*UnimplementedDemoServiceServer) LogAdd(ctx context.Context, req *LogAdd_Request) (*LogAdd_Reply, error)

+ func (*UnimplementedDemoServiceServer) LogGet(ctx context.Context, req *LogGet_Request) (*LogGet_Reply, error)

+ func (*UnimplementedDemoServiceServer) LogList(ctx context.Context, req *LogList_Request) (*LogList_Reply, error)

+ func (*UnimplementedDemoServiceServer) LogStream(req *LogStream_Request, srv DemoService_LogStreamServer) error

+ func (*UnimplementedDemoServiceServer) LogToken(ctx context.Context, req *LogToken_Request) (*LogToken_Reply, error)