Documentation
¶
Index ¶
- func RegisterDemoServiceServer(s *grpc.Server, srv DemoServiceServer)
- type DemoServiceClient
- type DemoServiceServer
- type DemoService_LogStreamClient
- type DemoService_LogStreamServer
- type LogAdd
- 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
- func (*LogAdd_Reply) Descriptor() ([]byte, []int)
- func (m *LogAdd_Reply) GetCid() string
- func (*LogAdd_Reply) ProtoMessage()
- 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
- func (*LogAdd_Request) Descriptor() ([]byte, []int)
- func (m *LogAdd_Request) GetData() []byte
- func (m *LogAdd_Request) GetLogToken() string
- func (*LogAdd_Request) ProtoMessage()
- 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
- 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
- func (*LogGet_Reply) Descriptor() ([]byte, []int)
- func (m *LogGet_Reply) GetOperation() *LogOperation
- func (*LogGet_Reply) ProtoMessage()
- 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
- func (*LogGet_Request) Descriptor() ([]byte, []int)
- func (m *LogGet_Request) GetCid() string
- func (m *LogGet_Request) GetLogToken() string
- func (*LogGet_Request) ProtoMessage()
- 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
- 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
- func (*LogList_Reply) Descriptor() ([]byte, []int)
- func (m *LogList_Reply) GetOperations() []*LogOperation
- func (*LogList_Reply) ProtoMessage()
- 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
- func (*LogList_Request) Descriptor() ([]byte, []int)
- func (m *LogList_Request) GetLogToken() string
- func (m *LogList_Request) GetOptions() *LogStreamOptions
- func (*LogList_Request) ProtoMessage()
- 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
- func (*LogOperation) Descriptor() ([]byte, []int)
- func (m *LogOperation) GetCid() string
- func (m *LogOperation) GetName() string
- func (m *LogOperation) GetValue() []byte
- func (*LogOperation) ProtoMessage()
- 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
- 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
- func (*LogStreamOptions) Descriptor() ([]byte, []int)
- 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 (*LogStreamOptions) ProtoMessage()
- 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
- func (*LogStream_Request) Descriptor() ([]byte, []int)
- func (m *LogStream_Request) GetLogToken() string
- func (m *LogStream_Request) GetOptions() *LogStreamOptions
- func (*LogStream_Request) ProtoMessage()
- 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
- 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
- func (*LogToken_Reply) Descriptor() ([]byte, []int)
- func (m *LogToken_Reply) GetLogToken() string
- func (*LogToken_Reply) ProtoMessage()
- 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
- 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
- type Service
- 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)
- type UnimplementedDemoServiceServer
- 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDemoServiceServer ¶
func RegisterDemoServiceServer(s *grpc.Server, srv DemoServiceServer)
Types ¶
type DemoServiceClient ¶
type DemoServiceClient interface { // LogToken Generates a token to feed to other methods. Does not open or create a log LogToken(ctx context.Context, in *LogToken_Request, opts ...grpc.CallOption) (*LogToken_Reply, error) // LogAdd Appends data to a log. Will create or open the log identified by the token LogAdd(ctx context.Context, in *LogAdd_Request, opts ...grpc.CallOption) (*LogAdd_Reply, error) // LogGet Gets a log entry by cid. Will create or open the log identified by the token LogGet(ctx context.Context, in *LogGet_Request, opts ...grpc.CallOption) (*LogGet_Reply, error) // LogList Fetches a list of operation that occurred on a log. Will create or open the log identified by the token LogList(ctx context.Context, in *LogList_Request, opts ...grpc.CallOption) (*LogList_Reply, error) // LogStream Stream operations that occur on a log. Will create or open the log identified by the token LogStream(ctx context.Context, in *LogStream_Request, opts ...grpc.CallOption) (DemoService_LogStreamClient, error) }
DemoServiceClient is the client API for DemoService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDemoServiceClient ¶
func NewDemoServiceClient(cc *grpc.ClientConn) DemoServiceClient
type DemoServiceServer ¶
type DemoServiceServer interface { // LogToken Generates a token to feed to other methods. Does not open or create a log LogToken(context.Context, *LogToken_Request) (*LogToken_Reply, error) // LogAdd Appends data to a log. Will create or open the log identified by the token LogAdd(context.Context, *LogAdd_Request) (*LogAdd_Reply, error) // LogGet Gets a log entry by cid. Will create or open the log identified by the token LogGet(context.Context, *LogGet_Request) (*LogGet_Reply, error) // LogList Fetches a list of operation that occurred on a log. Will create or open the log identified by the token LogList(context.Context, *LogList_Request) (*LogList_Reply, error) // LogStream Stream operations that occur on a log. Will create or open the log identified by the token LogStream(*LogStream_Request, DemoService_LogStreamServer) error }
DemoServiceServer is the server API for DemoService service.
type DemoService_LogStreamClient ¶
type DemoService_LogStreamClient interface { Recv() (*LogOperation, error) grpc.ClientStream }
type DemoService_LogStreamServer ¶
type DemoService_LogStreamServer interface { Send(*LogOperation) error grpc.ServerStream }
type LogAdd ¶
type LogAdd struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogAdd) Descriptor ¶
func (*LogAdd) ProtoMessage ¶
func (*LogAdd) ProtoMessage()
func (*LogAdd) XXX_DiscardUnknown ¶
func (m *LogAdd) XXX_DiscardUnknown()
func (*LogAdd) XXX_Marshal ¶
func (*LogAdd) XXX_Unmarshal ¶
type LogAdd_Reply ¶
type LogAdd_Reply struct { Cid string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogAdd_Reply) Descriptor ¶
func (*LogAdd_Reply) Descriptor() ([]byte, []int)
func (*LogAdd_Reply) GetCid ¶
func (m *LogAdd_Reply) GetCid() string
func (*LogAdd_Reply) ProtoMessage ¶
func (*LogAdd_Reply) ProtoMessage()
func (*LogAdd_Reply) Reset ¶
func (m *LogAdd_Reply) Reset()
func (*LogAdd_Reply) String ¶
func (m *LogAdd_Reply) String() string
func (*LogAdd_Reply) XXX_DiscardUnknown ¶
func (m *LogAdd_Reply) XXX_DiscardUnknown()
func (*LogAdd_Reply) XXX_Marshal ¶
func (m *LogAdd_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogAdd_Reply) XXX_Merge ¶
func (m *LogAdd_Reply) XXX_Merge(src proto.Message)
func (*LogAdd_Reply) XXX_Size ¶
func (m *LogAdd_Reply) XXX_Size() int
func (*LogAdd_Reply) XXX_Unmarshal ¶
func (m *LogAdd_Reply) XXX_Unmarshal(b []byte) error
type LogAdd_Request ¶
type LogAdd_Request struct { LogToken string `protobuf:"bytes,1,opt,name=log_token,json=logToken,proto3" json:"log_token,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 (*LogAdd_Request) Descriptor ¶
func (*LogAdd_Request) Descriptor() ([]byte, []int)
func (*LogAdd_Request) GetData ¶
func (m *LogAdd_Request) GetData() []byte
func (*LogAdd_Request) GetLogToken ¶
func (m *LogAdd_Request) GetLogToken() string
func (*LogAdd_Request) ProtoMessage ¶
func (*LogAdd_Request) ProtoMessage()
func (*LogAdd_Request) Reset ¶
func (m *LogAdd_Request) Reset()
func (*LogAdd_Request) String ¶
func (m *LogAdd_Request) String() string
func (*LogAdd_Request) XXX_DiscardUnknown ¶
func (m *LogAdd_Request) XXX_DiscardUnknown()
func (*LogAdd_Request) XXX_Marshal ¶
func (m *LogAdd_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogAdd_Request) XXX_Merge ¶
func (m *LogAdd_Request) XXX_Merge(src proto.Message)
func (*LogAdd_Request) XXX_Size ¶
func (m *LogAdd_Request) XXX_Size() int
func (*LogAdd_Request) XXX_Unmarshal ¶
func (m *LogAdd_Request) XXX_Unmarshal(b []byte) error
type LogGet ¶
type LogGet struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogGet) Descriptor ¶
func (*LogGet) ProtoMessage ¶
func (*LogGet) ProtoMessage()
func (*LogGet) XXX_DiscardUnknown ¶
func (m *LogGet) XXX_DiscardUnknown()
func (*LogGet) XXX_Marshal ¶
func (*LogGet) XXX_Unmarshal ¶
type LogGet_Reply ¶
type LogGet_Reply struct { Operation *LogOperation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogGet_Reply) Descriptor ¶
func (*LogGet_Reply) Descriptor() ([]byte, []int)
func (*LogGet_Reply) GetOperation ¶
func (m *LogGet_Reply) GetOperation() *LogOperation
func (*LogGet_Reply) ProtoMessage ¶
func (*LogGet_Reply) ProtoMessage()
func (*LogGet_Reply) Reset ¶
func (m *LogGet_Reply) Reset()
func (*LogGet_Reply) String ¶
func (m *LogGet_Reply) String() string
func (*LogGet_Reply) XXX_DiscardUnknown ¶
func (m *LogGet_Reply) XXX_DiscardUnknown()
func (*LogGet_Reply) XXX_Marshal ¶
func (m *LogGet_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogGet_Reply) XXX_Merge ¶
func (m *LogGet_Reply) XXX_Merge(src proto.Message)
func (*LogGet_Reply) XXX_Size ¶
func (m *LogGet_Reply) XXX_Size() int
func (*LogGet_Reply) XXX_Unmarshal ¶
func (m *LogGet_Reply) XXX_Unmarshal(b []byte) error
type LogGet_Request ¶
type LogGet_Request struct { LogToken string `protobuf:"bytes,1,opt,name=log_token,json=logToken,proto3" json:"log_token,omitempty"` Cid string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogGet_Request) Descriptor ¶
func (*LogGet_Request) Descriptor() ([]byte, []int)
func (*LogGet_Request) GetCid ¶
func (m *LogGet_Request) GetCid() string
func (*LogGet_Request) GetLogToken ¶
func (m *LogGet_Request) GetLogToken() string
func (*LogGet_Request) ProtoMessage ¶
func (*LogGet_Request) ProtoMessage()
func (*LogGet_Request) Reset ¶
func (m *LogGet_Request) Reset()
func (*LogGet_Request) String ¶
func (m *LogGet_Request) String() string
func (*LogGet_Request) XXX_DiscardUnknown ¶
func (m *LogGet_Request) XXX_DiscardUnknown()
func (*LogGet_Request) XXX_Marshal ¶
func (m *LogGet_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogGet_Request) XXX_Merge ¶
func (m *LogGet_Request) XXX_Merge(src proto.Message)
func (*LogGet_Request) XXX_Size ¶
func (m *LogGet_Request) XXX_Size() int
func (*LogGet_Request) XXX_Unmarshal ¶
func (m *LogGet_Request) XXX_Unmarshal(b []byte) error
type LogList ¶
type LogList struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogList) Descriptor ¶
func (*LogList) ProtoMessage ¶
func (*LogList) ProtoMessage()
func (*LogList) XXX_DiscardUnknown ¶
func (m *LogList) XXX_DiscardUnknown()
func (*LogList) XXX_Marshal ¶
func (*LogList) XXX_Unmarshal ¶
type LogList_Reply ¶
type LogList_Reply struct { Operations []*LogOperation `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogList_Reply) Descriptor ¶
func (*LogList_Reply) Descriptor() ([]byte, []int)
func (*LogList_Reply) GetOperations ¶
func (m *LogList_Reply) GetOperations() []*LogOperation
func (*LogList_Reply) ProtoMessage ¶
func (*LogList_Reply) ProtoMessage()
func (*LogList_Reply) Reset ¶
func (m *LogList_Reply) Reset()
func (*LogList_Reply) String ¶
func (m *LogList_Reply) String() string
func (*LogList_Reply) XXX_DiscardUnknown ¶
func (m *LogList_Reply) XXX_DiscardUnknown()
func (*LogList_Reply) XXX_Marshal ¶
func (m *LogList_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogList_Reply) XXX_Merge ¶
func (m *LogList_Reply) XXX_Merge(src proto.Message)
func (*LogList_Reply) XXX_Size ¶
func (m *LogList_Reply) XXX_Size() int
func (*LogList_Reply) XXX_Unmarshal ¶
func (m *LogList_Reply) XXX_Unmarshal(b []byte) error
type LogList_Request ¶
type LogList_Request struct { LogToken string `protobuf:"bytes,1,opt,name=log_token,json=logToken,proto3" json:"log_token,omitempty"` Options *LogStreamOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogList_Request) Descriptor ¶
func (*LogList_Request) Descriptor() ([]byte, []int)
func (*LogList_Request) GetLogToken ¶
func (m *LogList_Request) GetLogToken() string
func (*LogList_Request) GetOptions ¶
func (m *LogList_Request) GetOptions() *LogStreamOptions
func (*LogList_Request) ProtoMessage ¶
func (*LogList_Request) ProtoMessage()
func (*LogList_Request) Reset ¶
func (m *LogList_Request) Reset()
func (*LogList_Request) String ¶
func (m *LogList_Request) String() string
func (*LogList_Request) XXX_DiscardUnknown ¶
func (m *LogList_Request) XXX_DiscardUnknown()
func (*LogList_Request) XXX_Marshal ¶
func (m *LogList_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogList_Request) XXX_Merge ¶
func (m *LogList_Request) XXX_Merge(src proto.Message)
func (*LogList_Request) XXX_Size ¶
func (m *LogList_Request) XXX_Size() int
func (*LogList_Request) XXX_Unmarshal ¶
func (m *LogList_Request) XXX_Unmarshal(b []byte) error
type LogOperation ¶
type LogOperation struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Value []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` Cid string `protobuf:"bytes,3,opt,name=cid,proto3" json:"cid,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogOperation) Descriptor ¶
func (*LogOperation) Descriptor() ([]byte, []int)
func (*LogOperation) GetCid ¶
func (m *LogOperation) GetCid() string
func (*LogOperation) GetName ¶
func (m *LogOperation) GetName() string
func (*LogOperation) GetValue ¶
func (m *LogOperation) GetValue() []byte
func (*LogOperation) ProtoMessage ¶
func (*LogOperation) ProtoMessage()
func (*LogOperation) Reset ¶
func (m *LogOperation) Reset()
func (*LogOperation) String ¶
func (m *LogOperation) String() string
func (*LogOperation) XXX_DiscardUnknown ¶
func (m *LogOperation) XXX_DiscardUnknown()
func (*LogOperation) XXX_Marshal ¶
func (m *LogOperation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogOperation) XXX_Merge ¶
func (m *LogOperation) XXX_Merge(src proto.Message)
func (*LogOperation) XXX_Size ¶
func (m *LogOperation) XXX_Size() int
func (*LogOperation) XXX_Unmarshal ¶
func (m *LogOperation) XXX_Unmarshal(b []byte) error
type LogStream ¶
type LogStream struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogStream) Descriptor ¶
func (*LogStream) ProtoMessage ¶
func (*LogStream) ProtoMessage()
func (*LogStream) XXX_DiscardUnknown ¶
func (m *LogStream) XXX_DiscardUnknown()
func (*LogStream) XXX_Marshal ¶
func (*LogStream) XXX_Unmarshal ¶
type LogStreamOptions ¶
type LogStreamOptions struct { GT string `protobuf:"bytes,1,opt,name=GT,proto3" json:"GT,omitempty"` GTE string `protobuf:"bytes,2,opt,name=GTE,proto3" json:"GTE,omitempty"` LT string `protobuf:"bytes,3,opt,name=LT,proto3" json:"LT,omitempty"` LTE string `protobuf:"bytes,4,opt,name=LTE,proto3" json:"LTE,omitempty"` Amount uint32 `protobuf:"varint,5,opt,name=amount,proto3" json:"amount,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogStreamOptions) Descriptor ¶
func (*LogStreamOptions) Descriptor() ([]byte, []int)
func (*LogStreamOptions) GetAmount ¶
func (m *LogStreamOptions) GetAmount() uint32
func (*LogStreamOptions) GetGT ¶
func (m *LogStreamOptions) GetGT() string
func (*LogStreamOptions) GetGTE ¶
func (m *LogStreamOptions) GetGTE() string
func (*LogStreamOptions) GetLT ¶
func (m *LogStreamOptions) GetLT() string
func (*LogStreamOptions) GetLTE ¶
func (m *LogStreamOptions) GetLTE() string
func (*LogStreamOptions) ProtoMessage ¶
func (*LogStreamOptions) ProtoMessage()
func (*LogStreamOptions) Reset ¶
func (m *LogStreamOptions) Reset()
func (*LogStreamOptions) String ¶
func (m *LogStreamOptions) String() string
func (*LogStreamOptions) XXX_DiscardUnknown ¶
func (m *LogStreamOptions) XXX_DiscardUnknown()
func (*LogStreamOptions) XXX_Marshal ¶
func (m *LogStreamOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogStreamOptions) XXX_Merge ¶
func (m *LogStreamOptions) XXX_Merge(src proto.Message)
func (*LogStreamOptions) XXX_Size ¶
func (m *LogStreamOptions) XXX_Size() int
func (*LogStreamOptions) XXX_Unmarshal ¶
func (m *LogStreamOptions) XXX_Unmarshal(b []byte) error
type LogStream_Request ¶
type LogStream_Request struct { LogToken string `protobuf:"bytes,1,opt,name=log_token,json=logToken,proto3" json:"log_token,omitempty"` Options *LogStreamOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogStream_Request) Descriptor ¶
func (*LogStream_Request) Descriptor() ([]byte, []int)
func (*LogStream_Request) GetLogToken ¶
func (m *LogStream_Request) GetLogToken() string
func (*LogStream_Request) GetOptions ¶
func (m *LogStream_Request) GetOptions() *LogStreamOptions
func (*LogStream_Request) ProtoMessage ¶
func (*LogStream_Request) ProtoMessage()
func (*LogStream_Request) Reset ¶
func (m *LogStream_Request) Reset()
func (*LogStream_Request) String ¶
func (m *LogStream_Request) String() string
func (*LogStream_Request) XXX_DiscardUnknown ¶
func (m *LogStream_Request) XXX_DiscardUnknown()
func (*LogStream_Request) XXX_Marshal ¶
func (m *LogStream_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogStream_Request) XXX_Merge ¶
func (m *LogStream_Request) XXX_Merge(src proto.Message)
func (*LogStream_Request) XXX_Size ¶
func (m *LogStream_Request) XXX_Size() int
func (*LogStream_Request) XXX_Unmarshal ¶
func (m *LogStream_Request) XXX_Unmarshal(b []byte) error
type LogToken ¶
type LogToken struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogToken) Descriptor ¶
func (*LogToken) ProtoMessage ¶
func (*LogToken) ProtoMessage()
func (*LogToken) XXX_DiscardUnknown ¶
func (m *LogToken) XXX_DiscardUnknown()
func (*LogToken) XXX_Marshal ¶
func (*LogToken) XXX_Unmarshal ¶
type LogToken_Reply ¶
type LogToken_Reply struct { LogToken string `protobuf:"bytes,1,opt,name=log_token,json=logToken,proto3" json:"log_token,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogToken_Reply) Descriptor ¶
func (*LogToken_Reply) Descriptor() ([]byte, []int)
func (*LogToken_Reply) GetLogToken ¶
func (m *LogToken_Reply) GetLogToken() string
func (*LogToken_Reply) ProtoMessage ¶
func (*LogToken_Reply) ProtoMessage()
func (*LogToken_Reply) Reset ¶
func (m *LogToken_Reply) Reset()
func (*LogToken_Reply) String ¶
func (m *LogToken_Reply) String() string
func (*LogToken_Reply) XXX_DiscardUnknown ¶
func (m *LogToken_Reply) XXX_DiscardUnknown()
func (*LogToken_Reply) XXX_Marshal ¶
func (m *LogToken_Reply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogToken_Reply) XXX_Merge ¶
func (m *LogToken_Reply) XXX_Merge(src proto.Message)
func (*LogToken_Reply) XXX_Size ¶
func (m *LogToken_Reply) XXX_Size() int
func (*LogToken_Reply) XXX_Unmarshal ¶
func (m *LogToken_Reply) XXX_Unmarshal(b []byte) error
type LogToken_Request ¶
type LogToken_Request struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*LogToken_Request) Descriptor ¶
func (*LogToken_Request) Descriptor() ([]byte, []int)
func (*LogToken_Request) ProtoMessage ¶
func (*LogToken_Request) ProtoMessage()
func (*LogToken_Request) Reset ¶
func (m *LogToken_Request) Reset()
func (*LogToken_Request) String ¶
func (m *LogToken_Request) String() string
func (*LogToken_Request) XXX_DiscardUnknown ¶
func (m *LogToken_Request) XXX_DiscardUnknown()
func (*LogToken_Request) XXX_Marshal ¶
func (m *LogToken_Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*LogToken_Request) XXX_Merge ¶
func (m *LogToken_Request) XXX_Merge(src proto.Message)
func (*LogToken_Request) XXX_Size ¶
func (m *LogToken_Request) XXX_Size() int
func (*LogToken_Request) XXX_Unmarshal ¶
func (m *LogToken_Request) XXX_Unmarshal(b []byte) error
type Opts ¶
type Opts struct { Logger *zap.Logger CoreAPI ipfs_interface.CoreAPI OrbitDBDirectory string }
type Service ¶ added in v2.35.0
type Service struct {
// contains filtered or unexported fields
}
func (*Service) LogAdd ¶ added in v2.35.0
func (s *Service) LogAdd(ctx context.Context, req *LogAdd_Request) (*LogAdd_Reply, error)
func (*Service) LogGet ¶ added in v2.35.0
func (s *Service) LogGet(ctx context.Context, req *LogGet_Request) (*LogGet_Reply, error)
func (*Service) LogList ¶ added in v2.35.0
func (s *Service) LogList(ctx context.Context, req *LogList_Request) (*LogList_Reply, error)
func (*Service) LogStream ¶ added in v2.35.0
func (s *Service) LogStream(req *LogStream_Request, srv DemoService_LogStreamServer) error
func (*Service) LogToken ¶ added in v2.35.0
func (s *Service) LogToken(ctx context.Context, _ *LogToken_Request) (*LogToken_Reply, error)
type UnimplementedDemoServiceServer ¶
type UnimplementedDemoServiceServer struct { }
UnimplementedDemoServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDemoServiceServer) LogAdd ¶
func (*UnimplementedDemoServiceServer) LogAdd(ctx context.Context, req *LogAdd_Request) (*LogAdd_Reply, error)
func (*UnimplementedDemoServiceServer) LogGet ¶
func (*UnimplementedDemoServiceServer) LogGet(ctx context.Context, req *LogGet_Request) (*LogGet_Reply, error)
func (*UnimplementedDemoServiceServer) LogList ¶
func (*UnimplementedDemoServiceServer) LogList(ctx context.Context, req *LogList_Request) (*LogList_Reply, error)
func (*UnimplementedDemoServiceServer) LogStream ¶
func (*UnimplementedDemoServiceServer) LogStream(req *LogStream_Request, srv DemoService_LogStreamServer) error
func (*UnimplementedDemoServiceServer) LogToken ¶
func (*UnimplementedDemoServiceServer) LogToken(ctx context.Context, req *LogToken_Request) (*LogToken_Reply, error)
Click to show internal directories.
Click to hide internal directories.