evntsrc_bridge

Documentation

Overview

Package evntsrc_bridge is a generated protocol buffer package.

It is generated from these files:

bridge.proto

It has these top-level messages:

PublishRequest
SubscribeRequest
GeneralResponse

Index

• Variables
• func RegisterBridgeServiceServer(s *grpc.Server, srv BridgeServiceServer)
• type BridgeServiceClient
  • func NewBridgeServiceClient(cc *grpc.ClientConn) BridgeServiceClient
• type BridgeServiceServer
• type BridgeService_SubscribeClient
• type BridgeService_SubscribeServer
• type GeneralResponse
  • func (*GeneralResponse) Descriptor() ([]byte, []int)
  • func (m *GeneralResponse) Marshal() (dAtA []byte, err error)
  • func (m *GeneralResponse) MarshalTo(dAtA []byte) (int, error)
  • func (*GeneralResponse) ProtoMessage()
  • func (m *GeneralResponse) Reset()
  • func (m *GeneralResponse) Size() (n int)
  • func (m *GeneralResponse) String() string
  • func (m *GeneralResponse) Unmarshal(dAtA []byte) error
  • func (*GeneralResponse) XXX_MessageName() string
• type PublishRequest
  • func (*PublishRequest) Descriptor() ([]byte, []int)
  • func (m *PublishRequest) GetEvent() *evntsrc_event.Event
  • func (m *PublishRequest) GetStream() int32
  • func (m *PublishRequest) Marshal() (dAtA []byte, err error)
  • func (m *PublishRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*PublishRequest) ProtoMessage()
  • func (m *PublishRequest) Reset()
  • func (m *PublishRequest) Size() (n int)
  • func (m *PublishRequest) String() string
  • func (m *PublishRequest) Unmarshal(dAtA []byte) error
  • func (*PublishRequest) XXX_MessageName() string
• type SubscribeRequest
  • func (*SubscribeRequest) Descriptor() ([]byte, []int)
  • func (m *SubscribeRequest) GetChannel() string
  • func (m *SubscribeRequest) GetStream() int32
  • func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)
  • func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)
  • func (*SubscribeRequest) ProtoMessage()
  • func (m *SubscribeRequest) Reset()
  • func (m *SubscribeRequest) Size() (n int)
  • func (m *SubscribeRequest) String() string
  • func (m *SubscribeRequest) Unmarshal(dAtA []byte) error
  • func (*SubscribeRequest) XXX_MessageName() string

Variables

var (
	ErrInvalidLengthBridge = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBridge   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterBridgeServiceServer

func RegisterBridgeServiceServer(s *grpc.Server, srv BridgeServiceServer)

Types

type BridgeServiceClient

type BridgeServiceClient interface {
	Publish(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*GeneralResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (BridgeService_SubscribeClient, error)
}

func NewBridgeServiceClient

func NewBridgeServiceClient(cc *grpc.ClientConn) BridgeServiceClient

type BridgeServiceServer

type BridgeServiceServer interface {
	Publish(context.Context, *PublishRequest) (*GeneralResponse, error)
	Subscribe(*SubscribeRequest, BridgeService_SubscribeServer) error
}

type BridgeService_SubscribeClient

type BridgeService_SubscribeClient interface {
	Recv() (*evntsrc_event.Event, error)
	grpc.ClientStream
}

type BridgeService_SubscribeServer

type BridgeService_SubscribeServer interface {
	Send(*evntsrc_event.Event) error
	grpc.ServerStream
}

type GeneralResponse

type GeneralResponse struct {
}

func (*GeneralResponse) Descriptor

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

func (*GeneralResponse) Marshal

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

func (*GeneralResponse) MarshalTo

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

func (*GeneralResponse) ProtoMessage

func (*GeneralResponse) ProtoMessage()

func (*GeneralResponse) Reset

func (m *GeneralResponse) Reset()

func (*GeneralResponse) Size

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

func (*GeneralResponse) String

func (m *GeneralResponse) String() string

func (*GeneralResponse) Unmarshal

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

func (*GeneralResponse) XXX_MessageName

func (*GeneralResponse) XXX_MessageName() string

type PublishRequest

type PublishRequest struct {
	Stream int32                `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"`
	Event  *evntsrc_event.Event `protobuf:"bytes,2,opt,name=event" json:"event,omitempty"`
}

func (*PublishRequest) Descriptor

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

func (*PublishRequest) GetEvent

func (m *PublishRequest) GetEvent() *evntsrc_event.Event

func (*PublishRequest) GetStream

func (m *PublishRequest) GetStream() int32

func (*PublishRequest) Marshal

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

func (*PublishRequest) MarshalTo

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

func (*PublishRequest) ProtoMessage

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) Reset

func (m *PublishRequest) Reset()

func (*PublishRequest) Size

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

func (*PublishRequest) String

func (m *PublishRequest) String() string

func (*PublishRequest) Unmarshal

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

func (*PublishRequest) XXX_MessageName

func (*PublishRequest) XXX_MessageName() string

type SubscribeRequest

type SubscribeRequest struct {
	Stream  int32  `protobuf:"varint,1,opt,name=Stream,proto3" json:"Stream,omitempty"`
	Channel string `protobuf:"bytes,2,opt,name=Channel,proto3" json:"Channel,omitempty"`
}

func (*SubscribeRequest) Descriptor

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

func (*SubscribeRequest) GetChannel

func (m *SubscribeRequest) GetChannel() string

func (*SubscribeRequest) GetStream

func (m *SubscribeRequest) GetStream() int32

func (*SubscribeRequest) Marshal

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

func (*SubscribeRequest) MarshalTo

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

func (*SubscribeRequest) ProtoMessage

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size

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

func (*SubscribeRequest) String

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal

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

func (*SubscribeRequest) XXX_MessageName

func (*SubscribeRequest) XXX_MessageName() string