Documentation ¶
Overview ¶
Package consumerstore is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- func RegisterConsumerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterConsumerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConsumerServiceClient) error
- func RegisterConsumerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterConsumerServiceServer(s *grpc.Server, srv ConsumerServiceServer)
- type AppLogConsumeRequest
- func (*AppLogConsumeRequest) Descriptor() ([]byte, []int)
- func (m *AppLogConsumeRequest) GetConsumerId() string
- func (m *AppLogConsumeRequest) GetOffset() string
- func (*AppLogConsumeRequest) ProtoMessage()
- func (m *AppLogConsumeRequest) Reset()
- func (m *AppLogConsumeRequest) String() string
- func (m *AppLogConsumeRequest) XXX_DiscardUnknown()
- func (m *AppLogConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppLogConsumeRequest) XXX_Merge(src proto.Message)
- func (m *AppLogConsumeRequest) XXX_Size() int
- func (m *AppLogConsumeRequest) XXX_Unmarshal(b []byte) error
- type AppLogConsumeResponse
- func (*AppLogConsumeResponse) Descriptor() ([]byte, []int)
- func (*AppLogConsumeResponse) ProtoMessage()
- func (m *AppLogConsumeResponse) Reset()
- func (m *AppLogConsumeResponse) String() string
- func (m *AppLogConsumeResponse) XXX_DiscardUnknown()
- func (m *AppLogConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *AppLogConsumeResponse) XXX_Merge(src proto.Message)
- func (m *AppLogConsumeResponse) XXX_Size() int
- func (m *AppLogConsumeResponse) XXX_Unmarshal(b []byte) error
- type ConsumerServiceClient
- type ConsumerServiceServer
- type GetAppLogConsumeRequest
- func (*GetAppLogConsumeRequest) Descriptor() ([]byte, []int)
- func (m *GetAppLogConsumeRequest) GetConsumerId() string
- func (*GetAppLogConsumeRequest) ProtoMessage()
- func (m *GetAppLogConsumeRequest) Reset()
- func (m *GetAppLogConsumeRequest) String() string
- func (m *GetAppLogConsumeRequest) XXX_DiscardUnknown()
- func (m *GetAppLogConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAppLogConsumeRequest) XXX_Merge(src proto.Message)
- func (m *GetAppLogConsumeRequest) XXX_Size() int
- func (m *GetAppLogConsumeRequest) XXX_Unmarshal(b []byte) error
- type GetAppLogConsumeResponse
- func (*GetAppLogConsumeResponse) Descriptor() ([]byte, []int)
- func (m *GetAppLogConsumeResponse) GetConsumerId() string
- func (m *GetAppLogConsumeResponse) GetOffset() string
- func (*GetAppLogConsumeResponse) ProtoMessage()
- func (m *GetAppLogConsumeResponse) Reset()
- func (m *GetAppLogConsumeResponse) String() string
- func (m *GetAppLogConsumeResponse) XXX_DiscardUnknown()
- func (m *GetAppLogConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetAppLogConsumeResponse) XXX_Merge(src proto.Message)
- func (m *GetAppLogConsumeResponse) XXX_Size() int
- func (m *GetAppLogConsumeResponse) XXX_Unmarshal(b []byte) error
- type HealthRequest
- func (*HealthRequest) Descriptor() ([]byte, []int)
- func (*HealthRequest) ProtoMessage()
- func (m *HealthRequest) Reset()
- func (m *HealthRequest) String() string
- func (m *HealthRequest) XXX_DiscardUnknown()
- func (m *HealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthRequest) XXX_Merge(src proto.Message)
- func (m *HealthRequest) XXX_Size() int
- func (m *HealthRequest) XXX_Unmarshal(b []byte) error
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)
- func (m *HealthResponse) GetMessage() string
- func (*HealthResponse) ProtoMessage()
- func (m *HealthResponse) Reset()
- func (m *HealthResponse) String() string
- func (m *HealthResponse) XXX_DiscardUnknown()
- func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *HealthResponse) XXX_Merge(src proto.Message)
- func (m *HealthResponse) XXX_Size() int
- func (m *HealthResponse) XXX_Unmarshal(b []byte) error
- type ListConsumersRequest
- func (*ListConsumersRequest) Descriptor() ([]byte, []int)
- func (*ListConsumersRequest) ProtoMessage()
- func (m *ListConsumersRequest) Reset()
- func (m *ListConsumersRequest) String() string
- func (m *ListConsumersRequest) XXX_DiscardUnknown()
- func (m *ListConsumersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListConsumersRequest) XXX_Merge(src proto.Message)
- func (m *ListConsumersRequest) XXX_Size() int
- func (m *ListConsumersRequest) XXX_Unmarshal(b []byte) error
- type ListConsumersResponse
- func (*ListConsumersResponse) Descriptor() ([]byte, []int)
- func (m *ListConsumersResponse) GetConsumers() []*GetAppLogConsumeResponse
- func (*ListConsumersResponse) ProtoMessage()
- func (m *ListConsumersResponse) Reset()
- func (m *ListConsumersResponse) String() string
- func (m *ListConsumersResponse) XXX_DiscardUnknown()
- func (m *ListConsumersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListConsumersResponse) XXX_Merge(src proto.Message)
- func (m *ListConsumersResponse) XXX_Size() int
- func (m *ListConsumersResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterConsumerServiceHandler ¶
func RegisterConsumerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterConsumerServiceHandler registers the http handlers for service ConsumerService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterConsumerServiceHandlerClient ¶
func RegisterConsumerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ConsumerServiceClient) error
RegisterConsumerServiceHandlerClient registers the http handlers for service ConsumerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ConsumerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ConsumerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ConsumerServiceClient" to call the correct interceptors.
func RegisterConsumerServiceHandlerFromEndpoint ¶
func RegisterConsumerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterConsumerServiceHandlerFromEndpoint is same as RegisterConsumerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterConsumerServiceServer ¶
func RegisterConsumerServiceServer(s *grpc.Server, srv ConsumerServiceServer)
Types ¶
type AppLogConsumeRequest ¶
type AppLogConsumeRequest struct { // the consumer id ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` Offset string `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AppLogConsumeRequest) Descriptor ¶
func (*AppLogConsumeRequest) Descriptor() ([]byte, []int)
func (*AppLogConsumeRequest) GetConsumerId ¶
func (m *AppLogConsumeRequest) GetConsumerId() string
func (*AppLogConsumeRequest) GetOffset ¶
func (m *AppLogConsumeRequest) GetOffset() string
func (*AppLogConsumeRequest) ProtoMessage ¶
func (*AppLogConsumeRequest) ProtoMessage()
func (*AppLogConsumeRequest) Reset ¶
func (m *AppLogConsumeRequest) Reset()
func (*AppLogConsumeRequest) String ¶
func (m *AppLogConsumeRequest) String() string
func (*AppLogConsumeRequest) XXX_DiscardUnknown ¶
func (m *AppLogConsumeRequest) XXX_DiscardUnknown()
func (*AppLogConsumeRequest) XXX_Marshal ¶
func (m *AppLogConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppLogConsumeRequest) XXX_Merge ¶
func (m *AppLogConsumeRequest) XXX_Merge(src proto.Message)
func (*AppLogConsumeRequest) XXX_Size ¶
func (m *AppLogConsumeRequest) XXX_Size() int
func (*AppLogConsumeRequest) XXX_Unmarshal ¶
func (m *AppLogConsumeRequest) XXX_Unmarshal(b []byte) error
type AppLogConsumeResponse ¶
type AppLogConsumeResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*AppLogConsumeResponse) Descriptor ¶
func (*AppLogConsumeResponse) Descriptor() ([]byte, []int)
func (*AppLogConsumeResponse) ProtoMessage ¶
func (*AppLogConsumeResponse) ProtoMessage()
func (*AppLogConsumeResponse) Reset ¶
func (m *AppLogConsumeResponse) Reset()
func (*AppLogConsumeResponse) String ¶
func (m *AppLogConsumeResponse) String() string
func (*AppLogConsumeResponse) XXX_DiscardUnknown ¶
func (m *AppLogConsumeResponse) XXX_DiscardUnknown()
func (*AppLogConsumeResponse) XXX_Marshal ¶
func (m *AppLogConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*AppLogConsumeResponse) XXX_Merge ¶
func (m *AppLogConsumeResponse) XXX_Merge(src proto.Message)
func (*AppLogConsumeResponse) XXX_Size ¶
func (m *AppLogConsumeResponse) XXX_Size() int
func (*AppLogConsumeResponse) XXX_Unmarshal ¶
func (m *AppLogConsumeResponse) XXX_Unmarshal(b []byte) error
type ConsumerServiceClient ¶
type ConsumerServiceClient interface { Healtz(ctx context.Context, in *HealthRequest, opts ...grpc.CallOption) (*HealthResponse, error) LogConsume(ctx context.Context, in *AppLogConsumeRequest, opts ...grpc.CallOption) (*AppLogConsumeResponse, error) GetLogConsume(ctx context.Context, in *GetAppLogConsumeRequest, opts ...grpc.CallOption) (*GetAppLogConsumeResponse, error) List(ctx context.Context, in *ListConsumersRequest, opts ...grpc.CallOption) (*ListConsumersResponse, error) }
ConsumerServiceClient is the client API for ConsumerService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewConsumerServiceClient ¶
func NewConsumerServiceClient(cc *grpc.ClientConn) ConsumerServiceClient
type ConsumerServiceServer ¶
type ConsumerServiceServer interface { Healtz(context.Context, *HealthRequest) (*HealthResponse, error) LogConsume(context.Context, *AppLogConsumeRequest) (*AppLogConsumeResponse, error) GetLogConsume(context.Context, *GetAppLogConsumeRequest) (*GetAppLogConsumeResponse, error) List(context.Context, *ListConsumersRequest) (*ListConsumersResponse, error) }
ConsumerServiceServer is the server API for ConsumerService service.
type GetAppLogConsumeRequest ¶
type GetAppLogConsumeRequest struct { ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAppLogConsumeRequest) Descriptor ¶
func (*GetAppLogConsumeRequest) Descriptor() ([]byte, []int)
func (*GetAppLogConsumeRequest) GetConsumerId ¶
func (m *GetAppLogConsumeRequest) GetConsumerId() string
func (*GetAppLogConsumeRequest) ProtoMessage ¶
func (*GetAppLogConsumeRequest) ProtoMessage()
func (*GetAppLogConsumeRequest) Reset ¶
func (m *GetAppLogConsumeRequest) Reset()
func (*GetAppLogConsumeRequest) String ¶
func (m *GetAppLogConsumeRequest) String() string
func (*GetAppLogConsumeRequest) XXX_DiscardUnknown ¶
func (m *GetAppLogConsumeRequest) XXX_DiscardUnknown()
func (*GetAppLogConsumeRequest) XXX_Marshal ¶
func (m *GetAppLogConsumeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAppLogConsumeRequest) XXX_Merge ¶
func (m *GetAppLogConsumeRequest) XXX_Merge(src proto.Message)
func (*GetAppLogConsumeRequest) XXX_Size ¶
func (m *GetAppLogConsumeRequest) XXX_Size() int
func (*GetAppLogConsumeRequest) XXX_Unmarshal ¶
func (m *GetAppLogConsumeRequest) XXX_Unmarshal(b []byte) error
type GetAppLogConsumeResponse ¶
type GetAppLogConsumeResponse struct { ConsumerId string `protobuf:"bytes,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"` Offset string `protobuf:"bytes,2,opt,name=offset,proto3" json:"offset,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetAppLogConsumeResponse) Descriptor ¶
func (*GetAppLogConsumeResponse) Descriptor() ([]byte, []int)
func (*GetAppLogConsumeResponse) GetConsumerId ¶
func (m *GetAppLogConsumeResponse) GetConsumerId() string
func (*GetAppLogConsumeResponse) GetOffset ¶
func (m *GetAppLogConsumeResponse) GetOffset() string
func (*GetAppLogConsumeResponse) ProtoMessage ¶
func (*GetAppLogConsumeResponse) ProtoMessage()
func (*GetAppLogConsumeResponse) Reset ¶
func (m *GetAppLogConsumeResponse) Reset()
func (*GetAppLogConsumeResponse) String ¶
func (m *GetAppLogConsumeResponse) String() string
func (*GetAppLogConsumeResponse) XXX_DiscardUnknown ¶
func (m *GetAppLogConsumeResponse) XXX_DiscardUnknown()
func (*GetAppLogConsumeResponse) XXX_Marshal ¶
func (m *GetAppLogConsumeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetAppLogConsumeResponse) XXX_Merge ¶
func (m *GetAppLogConsumeResponse) XXX_Merge(src proto.Message)
func (*GetAppLogConsumeResponse) XXX_Size ¶
func (m *GetAppLogConsumeResponse) XXX_Size() int
func (*GetAppLogConsumeResponse) XXX_Unmarshal ¶
func (m *GetAppLogConsumeResponse) XXX_Unmarshal(b []byte) error
type HealthRequest ¶
type HealthRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthRequest) Descriptor ¶
func (*HealthRequest) Descriptor() ([]byte, []int)
func (*HealthRequest) ProtoMessage ¶
func (*HealthRequest) ProtoMessage()
func (*HealthRequest) Reset ¶
func (m *HealthRequest) Reset()
func (*HealthRequest) String ¶
func (m *HealthRequest) String() string
func (*HealthRequest) XXX_DiscardUnknown ¶
func (m *HealthRequest) XXX_DiscardUnknown()
func (*HealthRequest) XXX_Marshal ¶
func (m *HealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthRequest) XXX_Merge ¶
func (m *HealthRequest) XXX_Merge(src proto.Message)
func (*HealthRequest) XXX_Size ¶
func (m *HealthRequest) XXX_Size() int
func (*HealthRequest) XXX_Unmarshal ¶
func (m *HealthRequest) XXX_Unmarshal(b []byte) error
type HealthResponse ¶
type HealthResponse struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*HealthResponse) Descriptor ¶
func (*HealthResponse) Descriptor() ([]byte, []int)
func (*HealthResponse) GetMessage ¶
func (m *HealthResponse) GetMessage() string
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) Reset ¶
func (m *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (m *HealthResponse) String() string
func (*HealthResponse) XXX_DiscardUnknown ¶
func (m *HealthResponse) XXX_DiscardUnknown()
func (*HealthResponse) XXX_Marshal ¶
func (m *HealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*HealthResponse) XXX_Merge ¶
func (m *HealthResponse) XXX_Merge(src proto.Message)
func (*HealthResponse) XXX_Size ¶
func (m *HealthResponse) XXX_Size() int
func (*HealthResponse) XXX_Unmarshal ¶
func (m *HealthResponse) XXX_Unmarshal(b []byte) error
type ListConsumersRequest ¶
type ListConsumersRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListConsumersRequest) Descriptor ¶
func (*ListConsumersRequest) Descriptor() ([]byte, []int)
func (*ListConsumersRequest) ProtoMessage ¶
func (*ListConsumersRequest) ProtoMessage()
func (*ListConsumersRequest) Reset ¶
func (m *ListConsumersRequest) Reset()
func (*ListConsumersRequest) String ¶
func (m *ListConsumersRequest) String() string
func (*ListConsumersRequest) XXX_DiscardUnknown ¶
func (m *ListConsumersRequest) XXX_DiscardUnknown()
func (*ListConsumersRequest) XXX_Marshal ¶
func (m *ListConsumersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListConsumersRequest) XXX_Merge ¶
func (m *ListConsumersRequest) XXX_Merge(src proto.Message)
func (*ListConsumersRequest) XXX_Size ¶
func (m *ListConsumersRequest) XXX_Size() int
func (*ListConsumersRequest) XXX_Unmarshal ¶
func (m *ListConsumersRequest) XXX_Unmarshal(b []byte) error
type ListConsumersResponse ¶
type ListConsumersResponse struct { Consumers []*GetAppLogConsumeResponse `protobuf:"bytes,1,rep,name=consumers,proto3" json:"consumers,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ListConsumersResponse) Descriptor ¶
func (*ListConsumersResponse) Descriptor() ([]byte, []int)
func (*ListConsumersResponse) GetConsumers ¶
func (m *ListConsumersResponse) GetConsumers() []*GetAppLogConsumeResponse
func (*ListConsumersResponse) ProtoMessage ¶
func (*ListConsumersResponse) ProtoMessage()
func (*ListConsumersResponse) Reset ¶
func (m *ListConsumersResponse) Reset()
func (*ListConsumersResponse) String ¶
func (m *ListConsumersResponse) String() string
func (*ListConsumersResponse) XXX_DiscardUnknown ¶
func (m *ListConsumersResponse) XXX_DiscardUnknown()
func (*ListConsumersResponse) XXX_Marshal ¶
func (m *ListConsumersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListConsumersResponse) XXX_Merge ¶
func (m *ListConsumersResponse) XXX_Merge(src proto.Message)
func (*ListConsumersResponse) XXX_Size ¶
func (m *ListConsumersResponse) XXX_Size() int
func (*ListConsumersResponse) XXX_Unmarshal ¶
func (m *ListConsumersResponse) XXX_Unmarshal(b []byte) error