evntsrc_streams

package
v0.0.0-...-0172641 Latest Latest
Warning

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

 Go to latest Published: Sep 5, 2020 License: GPL-3.0 Imports: 15 Imported by: 0

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

Constants

This section is empty.

Variables

View Source 
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) Descriptor() ([]byte, []int)

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

func (*Empty) XXX_MessageName 

func (*Empty) XXX_MessageName() string

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) MarshalTo 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*IdList) GetId 

func (m *IdList) GetId() []int32

func (*IdList) Marshal 

func (m *IdList) Marshal() (dAtA []byte, err error)

func (*IdList) MarshalTo 

func (m *IdList) MarshalTo(dAtA []byte) (int, error)

func (*IdList) ProtoMessage 

func (*IdList) ProtoMessage()

func (*IdList) Reset 

func (m *IdList) Reset()

func (*IdList) Size 

func (m *IdList) Size() (n int)

func (*IdList) String 

func (m *IdList) String() string

func (*IdList) Unmarshal 

func (m *IdList) Unmarshal(dAtA []byte) error

func (*IdList) XXX_MessageName 

func (*IdList) XXX_MessageName() string

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) MarshalTo 

func (m *SearchRequest) MarshalTo(dAtA []byte) (int, 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) Descriptor() ([]byte, []int)

func (*Stream) GetCluster 

func (m *Stream) GetCluster() string

func (*Stream) GetColor 

func (m *Stream) GetColor() string

func (*Stream) GetIcon 

func (m *Stream) GetIcon() string

func (*Stream) GetId 

func (m *Stream) GetId() int32

func (*Stream) GetMetadata 

func (m *Stream) GetMetadata() map[string][]byte

func (*Stream) GetName 

func (m *Stream) GetName() string

func (*Stream) GetOwner 

func (m *Stream) GetOwner() string

func (*Stream) Marshal 

func (m *Stream) Marshal() (dAtA []byte, err error)

func (*Stream) MarshalTo 

func (m *Stream) MarshalTo(dAtA []byte) (int, error)

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

func (m *Stream) Size() (n int)

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Unmarshal 

func (m *Stream) Unmarshal(dAtA []byte) error

func (*Stream) XXX_MessageName 

func (*Stream) XXX_MessageName() string

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) MarshalTo 

func (m *StreamList) MarshalTo(dAtA []byte) (int, 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)
}

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.