Documentation ¶
Overview ¶
Package evntsrc_streams is a generated protocol buffer package. It is generated from these files: streams.proto It has these top-level messages: Stream SearchRequest StreamList Empty GetRequest IdList
Package evntsrc_streams is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Variables
- func RegisterStreamsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterStreamsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StreamsServiceClient) error
- func RegisterStreamsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterStreamsServiceServer(s *grpc.Server, srv StreamsServiceServer)
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (m *Empty) Marshal() (dAtA []byte, err error)
- func (m *Empty) MarshalTo(dAtA []byte) (int, error)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) Size() (n int)
- func (m *Empty) String() string
- func (m *Empty) Unmarshal(dAtA []byte) error
- func (*Empty) XXX_MessageName() string
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetId() int32
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (*GetRequest) XXX_MessageName() string
- type IdList
- func (*IdList) Descriptor() ([]byte, []int)
- func (m *IdList) GetId() []int32
- func (m *IdList) Marshal() (dAtA []byte, err error)
- func (m *IdList) MarshalTo(dAtA []byte) (int, error)
- func (*IdList) ProtoMessage()
- func (m *IdList) Reset()
- func (m *IdList) Size() (n int)
- func (m *IdList) String() string
- func (m *IdList) Unmarshal(dAtA []byte) error
- func (*IdList) XXX_MessageName() string
- type SearchRequest
- func (*SearchRequest) Descriptor() ([]byte, []int)
- func (m *SearchRequest) GetQuery() string
- func (m *SearchRequest) Marshal() (dAtA []byte, err error)
- func (m *SearchRequest) MarshalTo(dAtA []byte) (int, error)
- func (*SearchRequest) ProtoMessage()
- func (m *SearchRequest) Reset()
- func (m *SearchRequest) Size() (n int)
- func (m *SearchRequest) String() string
- func (m *SearchRequest) Unmarshal(dAtA []byte) error
- func (*SearchRequest) XXX_MessageName() string
- type Stream
- func (*Stream) Descriptor() ([]byte, []int)
- func (m *Stream) GetCluster() string
- func (m *Stream) GetColor() string
- func (m *Stream) GetIcon() string
- func (m *Stream) GetId() int32
- func (m *Stream) GetMetadata() map[string][]byte
- func (m *Stream) GetName() string
- func (m *Stream) GetOwner() string
- func (m *Stream) Marshal() (dAtA []byte, err error)
- func (m *Stream) MarshalTo(dAtA []byte) (int, error)
- func (*Stream) ProtoMessage()
- func (m *Stream) Reset()
- func (m *Stream) Size() (n int)
- func (m *Stream) String() string
- func (m *Stream) Unmarshal(dAtA []byte) error
- func (*Stream) XXX_MessageName() string
- type StreamList
- func (*StreamList) Descriptor() ([]byte, []int)
- func (m *StreamList) GetStreams() []*Stream
- func (m *StreamList) Marshal() (dAtA []byte, err error)
- func (m *StreamList) MarshalTo(dAtA []byte) (int, error)
- func (*StreamList) ProtoMessage()
- func (m *StreamList) Reset()
- func (m *StreamList) Size() (n int)
- func (m *StreamList) String() string
- func (m *StreamList) Unmarshal(dAtA []byte) error
- func (*StreamList) XXX_MessageName() string
- type StreamsServiceClient
- type StreamsServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthStreams = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowStreams = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterStreamsServiceHandler ¶
func RegisterStreamsServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterStreamsServiceHandler registers the http handlers for service StreamsService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterStreamsServiceHandlerClient ¶
func RegisterStreamsServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StreamsServiceClient) error
RegisterStreamsServiceHandlerClient registers the http handlers for service StreamsService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StreamsServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StreamsServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StreamsServiceClient" to call the correct interceptors.
func RegisterStreamsServiceHandlerFromEndpoint ¶
func RegisterStreamsServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterStreamsServiceHandlerFromEndpoint is same as RegisterStreamsServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterStreamsServiceServer ¶
func RegisterStreamsServiceServer(s *grpc.Server, srv StreamsServiceServer)
Types ¶
type Empty ¶
type Empty struct { }
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_MessageName ¶
type GetRequest ¶
type GetRequest struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetId ¶
func (m *GetRequest) GetId() int32
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_MessageName ¶
func (*GetRequest) XXX_MessageName() string
type IdList ¶
type IdList struct {
Id []int32 `protobuf:"varint,1,rep,packed,name=id" json:"id,omitempty"`
}
func (*IdList) Descriptor ¶
func (*IdList) ProtoMessage ¶
func (*IdList) ProtoMessage()
func (*IdList) XXX_MessageName ¶
type SearchRequest ¶
type SearchRequest struct {
Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
}
func (*SearchRequest) Descriptor ¶
func (*SearchRequest) Descriptor() ([]byte, []int)
func (*SearchRequest) GetQuery ¶
func (m *SearchRequest) GetQuery() string
func (*SearchRequest) Marshal ¶
func (m *SearchRequest) Marshal() (dAtA []byte, err error)
func (*SearchRequest) ProtoMessage ¶
func (*SearchRequest) ProtoMessage()
func (*SearchRequest) Reset ¶
func (m *SearchRequest) Reset()
func (*SearchRequest) Size ¶
func (m *SearchRequest) Size() (n int)
func (*SearchRequest) String ¶
func (m *SearchRequest) String() string
func (*SearchRequest) Unmarshal ¶
func (m *SearchRequest) Unmarshal(dAtA []byte) error
func (*SearchRequest) XXX_MessageName ¶
func (*SearchRequest) XXX_MessageName() string
type Stream ¶
type Stream struct { Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty" bson:"_id"` Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` Owner string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"` Icon string `protobuf:"bytes,5,opt,name=icon,proto3" json:"icon,omitempty"` Color string `protobuf:"bytes,6,opt,name=color,proto3" json:"color,omitempty"` Metadata map[string][]byte `` /* 150-byte string literal not displayed */ }
func (*Stream) Descriptor ¶
func (*Stream) GetCluster ¶
func (*Stream) GetMetadata ¶
func (*Stream) ProtoMessage ¶
func (*Stream) ProtoMessage()
func (*Stream) XXX_MessageName ¶
type StreamList ¶
type StreamList struct {
Streams []*Stream `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
}
func (*StreamList) Descriptor ¶
func (*StreamList) Descriptor() ([]byte, []int)
func (*StreamList) GetStreams ¶
func (m *StreamList) GetStreams() []*Stream
func (*StreamList) Marshal ¶
func (m *StreamList) Marshal() (dAtA []byte, err error)
func (*StreamList) ProtoMessage ¶
func (*StreamList) ProtoMessage()
func (*StreamList) Reset ¶
func (m *StreamList) Reset()
func (*StreamList) Size ¶
func (m *StreamList) Size() (n int)
func (*StreamList) String ¶
func (m *StreamList) String() string
func (*StreamList) Unmarshal ¶
func (m *StreamList) Unmarshal(dAtA []byte) error
func (*StreamList) XXX_MessageName ¶
func (*StreamList) XXX_MessageName() string
type StreamsServiceClient ¶
type StreamsServiceClient interface { Create(ctx context.Context, in *Stream, opts ...grpc.CallOption) (*Stream, error) List(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*StreamList, error) Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*Stream, error) Update(ctx context.Context, in *Stream, opts ...grpc.CallOption) (*Stream, error) Delete(ctx context.Context, in *Stream, opts ...grpc.CallOption) (*Empty, error) // Admin ListIds(ctx context.Context, in *SearchRequest, opts ...grpc.CallOption) (*IdList, error) }
func NewStreamsServiceClient ¶
func NewStreamsServiceClient(cc *grpc.ClientConn) StreamsServiceClient
type StreamsServiceServer ¶
type StreamsServiceServer interface { Create(context.Context, *Stream) (*Stream, error) List(context.Context, *Empty) (*StreamList, error) Get(context.Context, *GetRequest) (*Stream, error) Update(context.Context, *Stream) (*Stream, error) Delete(context.Context, *Stream) (*Empty, error) // Admin ListIds(context.Context, *SearchRequest) (*IdList, error) }