Documentation
¶
Overview ¶
Package grpc is a generated protocol buffer package.
It is generated from these files:
github.com/stratumn/go-indigonode/core/app/event/grpc/event.proto
It has these top-level messages:
ListenReq Event
Index ¶
- Variables
- func RegisterEmitterServer(s *grpc1.Server, srv EmitterServer)
- type EmitterClient
- type EmitterServer
- type Emitter_ListenClient
- type Emitter_ListenServer
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetLevel() Level
- func (m *Event) GetMessage() string
- func (m *Event) GetTopic() string
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- type Level
- type ListenReq
- func (*ListenReq) Descriptor() ([]byte, []int)
- func (m *ListenReq) GetTopic() string
- func (m *ListenReq) Marshal() (dAtA []byte, err error)
- func (m *ListenReq) MarshalTo(dAtA []byte) (int, error)
- func (*ListenReq) ProtoMessage()
- func (m *ListenReq) Reset()
- func (m *ListenReq) Size() (n int)
- func (m *ListenReq) String() string
- func (m *ListenReq) Unmarshal(dAtA []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthEvent = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowEvent = fmt.Errorf("proto: integer overflow") )
View Source
var Level_name = map[int32]string{
0: "INFO",
1: "DEBUG",
2: "WARNING",
3: "ERROR",
}
View Source
var Level_value = map[string]int32{
"INFO": 0,
"DEBUG": 1,
"WARNING": 2,
"ERROR": 3,
}
Functions ¶
func RegisterEmitterServer ¶
func RegisterEmitterServer(s *grpc1.Server, srv EmitterServer)
Types ¶
type EmitterClient ¶
type EmitterClient interface { // Listen starts listening to events. Listen(ctx context.Context, in *ListenReq, opts ...grpc1.CallOption) (Emitter_ListenClient, error) }
func NewEmitterClient ¶
func NewEmitterClient(cc *grpc1.ClientConn) EmitterClient
type EmitterServer ¶
type EmitterServer interface { // Listen starts listening to events. Listen(*ListenReq, Emitter_ListenServer) error }
type Emitter_ListenClient ¶
type Emitter_ListenClient interface { Recv() (*Event, error) grpc1.ClientStream }
type Emitter_ListenServer ¶
type Emitter_ListenServer interface { Send(*Event) error grpc1.ServerStream }
type Event ¶
type Event struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Level Level `protobuf:"varint,2,opt,name=level,proto3,enum=stratumn.indigonode.core.app.event.grpc.Level" json:"level,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` }
The Event message containing what should be displayed, with optional display customization (if supported by the listener).
func (*Event) Descriptor ¶
func (*Event) GetMessage ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
type ListenReq ¶
type ListenReq struct {
Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
}
The Listen request message.
func (*ListenReq) Descriptor ¶
func (*ListenReq) ProtoMessage ¶
func (*ListenReq) ProtoMessage()
Click to show internal directories.
Click to hide internal directories.