consumerstore

package
v0.0.0-...-783eb67 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2022 License: BSD-2-Clause Imports: 15 Imported by: 1

Documentation

Overview

Package consumerstore is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

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

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.