evntsrc_streamauth

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_streamauth is a generated protocol buffer package.

It is generated from these files:
	streamauth.proto

It has these top-level messages:
	APIPermissions
	Empty
	ListRequest
	GetRequest
	StreamKey
	KSRequest
	KeyList

Package evntsrc_streamauth is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStreamauth = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStreamauth   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterStreamAuthServiceHandler 

func RegisterStreamAuthServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterStreamAuthServiceHandler registers the http handlers for service StreamAuthService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterStreamAuthServiceHandlerClient 

func RegisterStreamAuthServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client StreamAuthServiceClient) error

RegisterStreamAuthServiceHandlerClient registers the http handlers for service StreamAuthService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "StreamAuthServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "StreamAuthServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "StreamAuthServiceClient" to call the correct interceptors.

func RegisterStreamAuthServiceHandlerFromEndpoint 

func RegisterStreamAuthServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterStreamAuthServiceHandlerFromEndpoint is same as RegisterStreamAuthServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterStreamAuthServiceServer 

func RegisterStreamAuthServiceServer(s *grpc.Server, srv StreamAuthServiceServer)

Types

type APIPermissions 

type APIPermissions struct {
	Publish   bool `protobuf:"varint,1,opt,name=publish,proto3" json:"publish,omitempty"`
	Subscribe bool `protobuf:"varint,2,opt,name=subscribe,proto3" json:"subscribe,omitempty"`
	Replay    bool `protobuf:"varint,3,opt,name=replay,proto3" json:"replay,omitempty"`
}

func (*APIPermissions) Descriptor 

func (*APIPermissions) Descriptor() ([]byte, []int)

func (*APIPermissions) GetPublish 

func (m *APIPermissions) GetPublish() bool

func (*APIPermissions) GetReplay 

func (m *APIPermissions) GetReplay() bool

func (*APIPermissions) GetSubscribe 

func (m *APIPermissions) GetSubscribe() bool

func (*APIPermissions) Marshal 

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

func (*APIPermissions) MarshalTo 

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

func (*APIPermissions) ProtoMessage 

func (*APIPermissions) ProtoMessage()

func (*APIPermissions) Reset 

func (m *APIPermissions) Reset()

func (*APIPermissions) Size 

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

func (*APIPermissions) String 

func (m *APIPermissions) String() string

func (*APIPermissions) Unmarshal 

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

func (*APIPermissions) XXX_MessageName 

func (*APIPermissions) XXX_MessageName() string

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 {
	Stream int32  `protobuf:"varint,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Id     string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty" bson:"_id"`
}

func (*GetRequest) Descriptor 

func (*GetRequest) Descriptor() ([]byte, []int)

func (*GetRequest) GetId 

func (m *GetRequest) GetId() string

func (*GetRequest) GetStream 

func (m *GetRequest) GetStream() 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 KSRequest 

type KSRequest struct {
	Stream int32  `protobuf:"varint,1,opt,name=stream,proto3" json:"stream,omitempty"`
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Secret string `protobuf:"bytes,3,opt,name=secret,proto3" json:"secret,omitempty"`
}

func (*KSRequest) Descriptor 

func (*KSRequest) Descriptor() ([]byte, []int)

func (*KSRequest) GetKey 

func (m *KSRequest) GetKey() string

func (*KSRequest) GetSecret 

func (m *KSRequest) GetSecret() string

func (*KSRequest) GetStream 

func (m *KSRequest) GetStream() int32

func (*KSRequest) Marshal 

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

func (*KSRequest) MarshalTo 

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

func (*KSRequest) ProtoMessage 

func (*KSRequest) ProtoMessage()

func (*KSRequest) Reset 

func (m *KSRequest) Reset()

func (*KSRequest) Size 

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

func (*KSRequest) String 

func (m *KSRequest) String() string

func (*KSRequest) Unmarshal 

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

func (*KSRequest) XXX_MessageName 

func (*KSRequest) XXX_MessageName() string

type KeyList 

type KeyList struct {
	Keys []*StreamKey `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
}

func (*KeyList) Descriptor 

func (*KeyList) Descriptor() ([]byte, []int)

func (*KeyList) GetKeys 

func (m *KeyList) GetKeys() []*StreamKey

func (*KeyList) Marshal 

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

func (*KeyList) MarshalTo 

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

func (*KeyList) ProtoMessage 

func (*KeyList) ProtoMessage()

func (*KeyList) Reset 

func (m *KeyList) Reset()

func (*KeyList) Size 

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

func (*KeyList) String 

func (m *KeyList) String() string

func (*KeyList) Unmarshal 

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

func (*KeyList) XXX_MessageName 

func (*KeyList) XXX_MessageName() string

type ListRequest 

type ListRequest struct {
	Stream int32 `protobuf:"varint,1,opt,name=stream,proto3" json:"stream,omitempty"`
}

func (*ListRequest) Descriptor 

func (*ListRequest) Descriptor() ([]byte, []int)

func (*ListRequest) GetStream 

func (m *ListRequest) GetStream() int32

func (*ListRequest) Marshal 

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

func (*ListRequest) MarshalTo 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) Size 

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

func (*ListRequest) String 

func (m *ListRequest) String() string

func (*ListRequest) Unmarshal 

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

func (*ListRequest) XXX_MessageName 

func (*ListRequest) XXX_MessageName() string

type StreamAuthServiceClient 

type StreamAuthServiceClient interface {
	Create(ctx context.Context, in *StreamKey, opts ...grpc.CallOption) (*StreamKey, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*KeyList, error)
	ListAll(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*KeyList, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*StreamKey, error)
	ValidateKeySecret(ctx context.Context, in *KSRequest, opts ...grpc.CallOption) (*StreamKey, error)
	Update(ctx context.Context, in *StreamKey, opts ...grpc.CallOption) (*StreamKey, error)
	Delete(ctx context.Context, in *StreamKey, opts ...grpc.CallOption) (*Empty, error)
}

func NewStreamAuthServiceClient 

func NewStreamAuthServiceClient(cc *grpc.ClientConn) StreamAuthServiceClient

type StreamAuthServiceServer 

type StreamAuthServiceServer interface {
	Create(context.Context, *StreamKey) (*StreamKey, error)
	List(context.Context, *ListRequest) (*KeyList, error)
	ListAll(context.Context, *Empty) (*KeyList, error)
	Get(context.Context, *GetRequest) (*StreamKey, error)
	ValidateKeySecret(context.Context, *KSRequest) (*StreamKey, error)
	Update(context.Context, *StreamKey) (*StreamKey, error)
	Delete(context.Context, *StreamKey) (*Empty, error)
}

type StreamKey 

type StreamKey struct {
	Id                string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty" bson:"_id"`
	Label             string            `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"`
	Stream            int32             `protobuf:"varint,3,opt,name=stream,proto3" json:"stream,omitempty"`
	Key               string            `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`
	Secret            string            `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	RestrictionFilter string            `protobuf:"bytes,6,opt,name=restrictionFilter,proto3" json:"restrictionFilter,omitempty"`
	Permissions       *APIPermissions   `protobuf:"bytes,7,opt,name=permissions" json:"permissions,omitempty"`
	Metadata          map[string][]byte `` /* 150-byte string literal not displayed */
}

func (*StreamKey) Descriptor 

func (*StreamKey) Descriptor() ([]byte, []int)

func (*StreamKey) GetId 

func (m *StreamKey) GetId() string

func (*StreamKey) GetKey 

func (m *StreamKey) GetKey() string

func (*StreamKey) GetLabel 

func (m *StreamKey) GetLabel() string

func (*StreamKey) GetMetadata 

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

func (*StreamKey) GetPermissions 

func (m *StreamKey) GetPermissions() *APIPermissions

func (*StreamKey) GetRestrictionFilter 

func (m *StreamKey) GetRestrictionFilter() string

func (*StreamKey) GetSecret 

func (m *StreamKey) GetSecret() string

func (*StreamKey) GetStream 

func (m *StreamKey) GetStream() int32

func (*StreamKey) Marshal 

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

func (*StreamKey) MarshalTo 

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

func (*StreamKey) ProtoMessage 

func (*StreamKey) ProtoMessage()

func (*StreamKey) Reset 

func (m *StreamKey) Reset()

func (*StreamKey) Size 

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

func (*StreamKey) String 

func (m *StreamKey) String() string

func (*StreamKey) Unmarshal 

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

func (*StreamKey) XXX_MessageName 

func (*StreamKey) XXX_MessageName() string

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.