api

Mar 22, 2022

Changes in this version

type API

+ func (x *API) Create(ctx context.Context, req *CreateRequest) (_ *empty.Empty, err error)

+ func (x *API) Delete(ctx context.Context, req *DeleteRequest) (_ *empty.Empty, err error)

+ func (x *API) Get(ctx context.Context, _ *empty.Empty) (rep *GetReply, err error)

+ func (x *API) Update(ctx context.Context, req *UpdateRequest) (_ *empty.Empty, err error)

type APIClient

+ Create func(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Delete func(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Get func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetReply, error)

+ Update func(ctx context.Context, in *UpdateRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

type APIServer

+ Create func(context.Context, *CreateRequest) (*emptypb.Empty, error)

+ Delete func(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ Get func(context.Context, *emptypb.Empty) (*GetReply, error)

+ Update func(context.Context, *UpdateRequest) (*emptypb.Empty, error)

+ type CreateRequest struct

+ Description string

+ Key string

+ Topic string

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

+ func (*CreateRequest) ProtoMessage()

+ func (x *CreateRequest) GetDescription() string

+ func (x *CreateRequest) GetKey() string

+ func (x *CreateRequest) GetTopic() string

+ func (x *CreateRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateRequest) Reset()

+ func (x *CreateRequest) String() string

+ type DeleteRequest struct

+ Key string

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

+ func (*DeleteRequest) ProtoMessage()

+ func (x *DeleteRequest) GetKey() string

+ func (x *DeleteRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteRequest) Reset()

+ func (x *DeleteRequest) String() string

+ type GetReply struct

+ Data []*Transfer

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

+ func (*GetReply) ProtoMessage()

+ func (x *GetReply) GetData() []*Transfer

+ func (x *GetReply) ProtoReflect() protoreflect.Message

+ func (x *GetReply) Reset()

+ func (x *GetReply) String() string

+ type Transfer struct

+ Description string

+ Key string

+ Topic string

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

+ func (*Transfer) ProtoMessage()

+ func (x *Transfer) GetDescription() string

+ func (x *Transfer) GetKey() string

+ func (x *Transfer) GetTopic() string

+ func (x *Transfer) ProtoReflect() protoreflect.Message

+ func (x *Transfer) Reset()

+ func (x *Transfer) String() string

type UnimplementedAPIServer

+ func (UnimplementedAPIServer) Create(context.Context, *CreateRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) Delete(context.Context, *DeleteRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) Get(context.Context, *emptypb.Empty) (*GetReply, error)

+ func (UnimplementedAPIServer) Update(context.Context, *UpdateRequest) (*emptypb.Empty, error)

+ type UpdateRequest struct

+ Description string

+ Key string

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

+ func (*UpdateRequest) ProtoMessage()

+ func (x *UpdateRequest) GetDescription() string

+ func (x *UpdateRequest) GetKey() string

+ func (x *UpdateRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateRequest) Reset()

+ func (x *UpdateRequest) String() string

Feb 22, 2022

Changes in this version

type CreateLoggerRequest

+ Key string

+ func (x *CreateLoggerRequest) GetKey() string

Feb 22, 2022

Changes in this version

+ var File_transfer_proto protoreflect.FileDescriptor

Feb 14, 2022

Changes in this version

+ var API_ServiceDesc = grpc.ServiceDesc

+ var File_api_proto protoreflect.FileDescriptor

+ var Provides = wire.NewSet(New)

+ func New(x *common.Inject) (s *grpc.Server, err error)

+ func RegisterAPIServer(s grpc.ServiceRegistrar, srv APIServer)

+ type API struct

+ func (x *API) CreateLogger(ctx context.Context, req *CreateLoggerRequest) (_ *empty.Empty, err error)

+ func (x *API) DeleteLogger(ctx context.Context, req *DeleteLoggerRequest) (_ *empty.Empty, err error)

+ func (x *API) GetLoggers(ctx context.Context, _ *empty.Empty) (rep *GetLoggersReply, err error)

+ func (x *API) Info(ctx context.Context, req *InfoRequest) (rep *InfoReply, err error)

+ func (x *API) Publish(ctx context.Context, req *PublishRequest) (_ *empty.Empty, err error)

+ func (x *API) UpdateLogger(ctx context.Context, req *UpdateLoggerRequest) (_ *empty.Empty, err error)

+ type APIClient interface

+ CreateLogger func(ctx context.Context, in *CreateLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteLogger func(ctx context.Context, in *DeleteLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetLoggers func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLoggersReply, error)

+ Info func(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoReply, error)

+ Publish func(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateLogger func(ctx context.Context, in *UpdateLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewAPIClient(cc grpc.ClientConnInterface) APIClient

+ type APIServer interface

+ CreateLogger func(context.Context, *CreateLoggerRequest) (*emptypb.Empty, error)

+ DeleteLogger func(context.Context, *DeleteLoggerRequest) (*emptypb.Empty, error)

+ GetLoggers func(context.Context, *emptypb.Empty) (*GetLoggersReply, error)

+ Info func(context.Context, *InfoRequest) (*InfoReply, error)

+ Publish func(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ UpdateLogger func(context.Context, *UpdateLoggerRequest) (*emptypb.Empty, error)

+ type CreateLoggerRequest struct

+ Description string

+ Topic string

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

+ func (*CreateLoggerRequest) ProtoMessage()

+ func (x *CreateLoggerRequest) GetDescription() string

+ func (x *CreateLoggerRequest) GetTopic() string

+ func (x *CreateLoggerRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateLoggerRequest) Reset()

+ func (x *CreateLoggerRequest) String() string

+ type DeleteLoggerRequest struct

+ Key string

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

+ func (*DeleteLoggerRequest) ProtoMessage()

+ func (x *DeleteLoggerRequest) GetKey() string

+ func (x *DeleteLoggerRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteLoggerRequest) Reset()

+ func (x *DeleteLoggerRequest) String() string

+ type GetLoggersReply struct

+ Data []*Logger

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

+ func (*GetLoggersReply) ProtoMessage()

+ func (x *GetLoggersReply) GetData() []*Logger

+ func (x *GetLoggersReply) ProtoReflect() protoreflect.Message

+ func (x *GetLoggersReply) Reset()

+ func (x *GetLoggersReply) String() string

+ type InfoReply struct

+ CreateTime int64

+ State *InfoState

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

+ func (*InfoReply) ProtoMessage()

+ func (x *InfoReply) GetCreateTime() int64

+ func (x *InfoReply) GetState() *InfoState

+ func (x *InfoReply) ProtoReflect() protoreflect.Message

+ func (x *InfoReply) Reset()

+ func (x *InfoReply) String() string

+ type InfoRequest struct

+ Key string

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

+ func (*InfoRequest) ProtoMessage()

+ func (x *InfoRequest) GetKey() string

+ func (x *InfoRequest) ProtoReflect() protoreflect.Message

+ func (x *InfoRequest) Reset()

+ func (x *InfoRequest) String() string

+ type InfoState struct

+ Bytes uint64

+ ConsumerCount int64

+ FirstSeq uint64

+ FirstTime int64

+ LastSeq uint64

+ LastTime int64

+ Messages uint64

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

+ func (*InfoState) ProtoMessage()

+ func (x *InfoState) GetBytes() uint64

+ func (x *InfoState) GetConsumerCount() int64

+ func (x *InfoState) GetFirstSeq() uint64

+ func (x *InfoState) GetFirstTime() int64

+ func (x *InfoState) GetLastSeq() uint64

+ func (x *InfoState) GetLastTime() int64

+ func (x *InfoState) GetMessages() uint64

+ func (x *InfoState) ProtoReflect() protoreflect.Message

+ func (x *InfoState) Reset()

+ func (x *InfoState) String() string

+ type Logger struct

+ Description string

+ Key string

+ Topic string

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

+ func (*Logger) ProtoMessage()

+ func (x *Logger) GetDescription() string

+ func (x *Logger) GetKey() string

+ func (x *Logger) GetTopic() string

+ func (x *Logger) ProtoReflect() protoreflect.Message

+ func (x *Logger) Reset()

+ func (x *Logger) String() string

+ type PublishRequest struct

+ Payload []byte

+ Topic string

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

+ func (*PublishRequest) ProtoMessage()

+ func (x *PublishRequest) GetPayload() []byte

+ func (x *PublishRequest) GetTopic() string

+ func (x *PublishRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishRequest) Reset()

+ func (x *PublishRequest) String() string

+ type UnimplementedAPIServer struct

+ func (UnimplementedAPIServer) CreateLogger(context.Context, *CreateLoggerRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) DeleteLogger(context.Context, *DeleteLoggerRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) GetLoggers(context.Context, *emptypb.Empty) (*GetLoggersReply, error)

+ func (UnimplementedAPIServer) Info(context.Context, *InfoRequest) (*InfoReply, error)

+ func (UnimplementedAPIServer) Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)

+ func (UnimplementedAPIServer) UpdateLogger(context.Context, *UpdateLoggerRequest) (*emptypb.Empty, error)

+ type UnsafeAPIServer interface

+ type UpdateLoggerRequest struct

+ Description string

+ Key string

+ Topic string

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

+ func (*UpdateLoggerRequest) ProtoMessage()

+ func (x *UpdateLoggerRequest) GetDescription() string

+ func (x *UpdateLoggerRequest) GetKey() string

+ func (x *UpdateLoggerRequest) GetTopic() string

+ func (x *UpdateLoggerRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateLoggerRequest) Reset()

+ func (x *UpdateLoggerRequest) String() string