bertydemo

package
v2.43.0 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2020 License: Apache-2.0, MIT Imports: 25 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterDemoServiceServer 

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

Types

type Client 

type Client interface {
	DemoServiceClient

	Close() error
}

func NewClient added in v2.39.0 

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

func NewClientFromServer added in v2.39.0 

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

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) Descriptor() ([]byte, []int)

func (*LogAdd) ProtoMessage 

func (*LogAdd) ProtoMessage()

func (*LogAdd) Reset 

func (m *LogAdd) Reset()

func (*LogAdd) String 

func (m *LogAdd) String() string

func (*LogAdd) XXX_DiscardUnknown 

func (m *LogAdd) XXX_DiscardUnknown()

func (*LogAdd) XXX_Marshal 

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

func (*LogAdd) XXX_Merge 

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

func (*LogAdd) XXX_Size 

func (m *LogAdd) XXX_Size() int

func (*LogAdd) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*LogGet) ProtoMessage 

func (*LogGet) ProtoMessage()

func (*LogGet) Reset 

func (m *LogGet) Reset()

func (*LogGet) String 

func (m *LogGet) String() string

func (*LogGet) XXX_DiscardUnknown 

func (m *LogGet) XXX_DiscardUnknown()

func (*LogGet) XXX_Marshal 

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

func (*LogGet) XXX_Merge 

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

func (*LogGet) XXX_Size 

func (m *LogGet) XXX_Size() int

func (*LogGet) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*LogList) ProtoMessage 

func (*LogList) ProtoMessage()

func (*LogList) Reset 

func (m *LogList) Reset()

func (*LogList) String 

func (m *LogList) String() string

func (*LogList) XXX_DiscardUnknown 

func (m *LogList) XXX_DiscardUnknown()

func (*LogList) XXX_Marshal 

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

func (*LogList) XXX_Merge 

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

func (*LogList) XXX_Size 

func (m *LogList) XXX_Size() int

func (*LogList) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*LogStream) ProtoMessage 

func (*LogStream) ProtoMessage()

func (*LogStream) Reset 

func (m *LogStream) Reset()

func (*LogStream) String 

func (m *LogStream) String() string

func (*LogStream) XXX_DiscardUnknown 

func (m *LogStream) XXX_DiscardUnknown()

func (*LogStream) XXX_Marshal 

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

func (*LogStream) XXX_Merge 

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

func (*LogStream) XXX_Size 

func (m *LogStream) XXX_Size() int

func (*LogStream) XXX_Unmarshal 

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

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) Descriptor() ([]byte, []int)

func (*LogToken) ProtoMessage 

func (*LogToken) ProtoMessage()

func (*LogToken) Reset 

func (m *LogToken) Reset()

func (*LogToken) String 

func (m *LogToken) String() string

func (*LogToken) XXX_DiscardUnknown 

func (m *LogToken) XXX_DiscardUnknown()

func (*LogToken) XXX_Marshal 

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

func (*LogToken) XXX_Merge 

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

func (*LogToken) XXX_Size 

func (m *LogToken) XXX_Size() int

func (*LogToken) XXX_Unmarshal 

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

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 New 

func New(opts *Opts) (*Service, error)

func (*Service) Close added in v2.35.0 

func (s *Service) Close() error

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)

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.