proto

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files:

stream.proto

It has these top-level messages:

Request
EventType
Payload

Index

• func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer)
• type EventType
  • func (*EventType) Descriptor() ([]byte, []int)
  • func (m *EventType) GetType() string
  • func (*EventType) ProtoMessage()
  • func (m *EventType) Reset()
  • func (m *EventType) String() string
• type Payload
  • func (*Payload) Descriptor() ([]byte, []int)
  • func (m *Payload) GetData() string
  • func (m *Payload) GetEventType() *EventType
  • func (*Payload) ProtoMessage()
  • func (m *Payload) Reset()
  • func (m *Payload) String() string
• type Request
  • func (*Request) Descriptor() ([]byte, []int)
  • func (m *Request) GetEvents() []*EventType
  • func (m *Request) GetForceClose() bool
  • func (*Request) ProtoMessage()
  • func (m *Request) Reset()
  • func (m *Request) String() string
• type StreamServiceClient
  • func NewStreamServiceClient(cc *grpc.ClientConn) StreamServiceClient
• type StreamServiceServer
• type StreamService_EventsClient
• type StreamService_EventsServer

Functions

func RegisterStreamServiceServer

func RegisterStreamServiceServer(s *grpc.Server, srv StreamServiceServer)

Types

type EventType

type EventType struct {
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
}

func (*EventType) Descriptor

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

func (*EventType) GetType

func (m *EventType) GetType() string

func (*EventType) ProtoMessage

func (*EventType) ProtoMessage()

func (*EventType) Reset

func (m *EventType) Reset()

func (*EventType) String

func (m *EventType) String() string

type Payload

type Payload struct {
	EventType *EventType `protobuf:"bytes,1,opt,name=eventType" json:"eventType,omitempty"`
	Data      string     `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
}

func (*Payload) Descriptor

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

func (*Payload) GetData

func (m *Payload) GetData() string

func (*Payload) GetEventType

func (m *Payload) GetEventType() *EventType

func (*Payload) ProtoMessage

func (*Payload) ProtoMessage()

func (*Payload) Reset

func (m *Payload) Reset()

func (*Payload) String

func (m *Payload) String() string

type Request

type Request struct {
	Events     []*EventType `protobuf:"bytes,1,rep,name=Events" json:"Events,omitempty"`
	ForceClose bool         `protobuf:"varint,2,opt,name=forceClose" json:"forceClose,omitempty"`
}

func (*Request) Descriptor

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

func (*Request) GetEvents

func (m *Request) GetEvents() []*EventType

func (*Request) GetForceClose

func (m *Request) GetForceClose() bool

func (*Request) ProtoMessage

func (*Request) ProtoMessage()

func (*Request) Reset

func (m *Request) Reset()

func (*Request) String

func (m *Request) String() string

type StreamServiceClient

type StreamServiceClient interface {
	Events(ctx context.Context, opts ...grpc.CallOption) (StreamService_EventsClient, error)
}

func NewStreamServiceClient

func NewStreamServiceClient(cc *grpc.ClientConn) StreamServiceClient

type StreamServiceServer

type StreamServiceServer interface {
	Events(StreamService_EventsServer) error
}

type StreamService_EventsClient

type StreamService_EventsClient interface {
	Send(*Request) error
	Recv() (*Payload, error)
	grpc.ClientStream
}

type StreamService_EventsServer

type StreamService_EventsServer interface {
	Send(*Payload) error
	Recv() (*Request, error)
	grpc.ServerStream
}