api

type API struct {
	UnimplementedAPIServer
	*common.Inject
}

type APIClient interface {
	GetLoggers(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetLoggersReply, error)
	CreateLogger(ctx context.Context, in *CreateLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	UpdateLogger(ctx context.Context, in *UpdateLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteLogger(ctx context.Context, in *DeleteLoggerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoReply, error)
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

type APIServer interface {
	GetLoggers(context.Context, *emptypb.Empty) (*GetLoggersReply, error)
	CreateLogger(context.Context, *CreateLoggerRequest) (*emptypb.Empty, error)
	UpdateLogger(context.Context, *UpdateLoggerRequest) (*emptypb.Empty, error)
	DeleteLogger(context.Context, *DeleteLoggerRequest) (*emptypb.Empty, error)
	Info(context.Context, *InfoRequest) (*InfoReply, error)
	Publish(context.Context, *PublishRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

type CreateLoggerRequest struct {
	Topic       string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type DeleteLoggerRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type GetLoggersReply struct {
	Data []*Logger `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type InfoReply struct {
	State      *InfoState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	CreateTime int64      `protobuf:"varint,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// contains filtered or unexported fields
}

type InfoRequest struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

type InfoState struct {
	Messages      uint64 `protobuf:"varint,1,opt,name=messages,proto3" json:"messages,omitempty"`
	Bytes         uint64 `protobuf:"varint,2,opt,name=bytes,proto3" json:"bytes,omitempty"`
	FirstSeq      uint64 `protobuf:"varint,3,opt,name=first_seq,json=firstSeq,proto3" json:"first_seq,omitempty"`
	FirstTime     int64  `protobuf:"varint,4,opt,name=first_time,json=firstTime,proto3" json:"first_time,omitempty"`
	LastSeq       uint64 `protobuf:"varint,5,opt,name=last_seq,json=lastSeq,proto3" json:"last_seq,omitempty"`
	LastTime      int64  `protobuf:"varint,6,opt,name=last_time,json=lastTime,proto3" json:"last_time,omitempty"`
	ConsumerCount int64  `protobuf:"varint,7,opt,name=consumer_count,json=consumerCount,proto3" json:"consumer_count,omitempty"`
	// contains filtered or unexported fields
}

type Logger struct {
	Key         string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Topic       string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type PublishRequest struct {
	Topic   string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAPIServer struct {
}

type UnsafeAPIServer interface {
	// contains filtered or unexported methods
}

type UpdateLoggerRequest struct {
	Key         string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Topic       string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}