Documentation ¶
Index ¶
- func RegisterNotificationServiceServer(s *grpc.Server, srv NotificationServiceServer)
- type Notification
- func (*Notification) Descriptor() ([]byte, []int)
- func (m *Notification) GetBody() string
- func (m *Notification) GetId() string
- func (m *Notification) GetService() string
- func (m *Notification) GetTopic() string
- func (*Notification) ProtoMessage()
- func (m *Notification) Reset()
- func (m *Notification) String() string
- func (m *Notification) XXX_DiscardUnknown()
- func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Notification) XXX_Merge(src proto.Message)
- func (m *Notification) XXX_Size() int
- func (m *Notification) XXX_Unmarshal(b []byte) error
- type NotificationServiceClient
- type NotificationServiceServer
- type SendNotificationRequest
- func (*SendNotificationRequest) Descriptor() ([]byte, []int)
- func (m *SendNotificationRequest) GetBody() string
- func (m *SendNotificationRequest) GetService() string
- func (m *SendNotificationRequest) GetTopic() string
- func (*SendNotificationRequest) ProtoMessage()
- func (m *SendNotificationRequest) Reset()
- func (m *SendNotificationRequest) String() string
- func (m *SendNotificationRequest) XXX_DiscardUnknown()
- func (m *SendNotificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendNotificationRequest) XXX_Merge(src proto.Message)
- func (m *SendNotificationRequest) XXX_Size() int
- func (m *SendNotificationRequest) XXX_Unmarshal(b []byte) error
- type SendNotificationResponse
- func (*SendNotificationResponse) Descriptor() ([]byte, []int)
- func (m *SendNotificationResponse) GetNotification() *Notification
- func (*SendNotificationResponse) ProtoMessage()
- func (m *SendNotificationResponse) Reset()
- func (m *SendNotificationResponse) String() string
- func (m *SendNotificationResponse) XXX_DiscardUnknown()
- func (m *SendNotificationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *SendNotificationResponse) XXX_Merge(src proto.Message)
- func (m *SendNotificationResponse) XXX_Size() int
- func (m *SendNotificationResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedNotificationServiceServer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterNotificationServiceServer ¶
func RegisterNotificationServiceServer(s *grpc.Server, srv NotificationServiceServer)
Types ¶
type Notification ¶
type Notification struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` Topic string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"` Body string `protobuf:"bytes,4,opt,name=body,proto3" json:"body,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Notification) Descriptor ¶
func (*Notification) Descriptor() ([]byte, []int)
func (*Notification) GetBody ¶
func (m *Notification) GetBody() string
func (*Notification) GetId ¶
func (m *Notification) GetId() string
func (*Notification) GetService ¶
func (m *Notification) GetService() string
func (*Notification) GetTopic ¶
func (m *Notification) GetTopic() string
func (*Notification) ProtoMessage ¶
func (*Notification) ProtoMessage()
func (*Notification) Reset ¶
func (m *Notification) Reset()
func (*Notification) String ¶
func (m *Notification) String() string
func (*Notification) XXX_DiscardUnknown ¶
func (m *Notification) XXX_DiscardUnknown()
func (*Notification) XXX_Marshal ¶
func (m *Notification) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Notification) XXX_Merge ¶
func (m *Notification) XXX_Merge(src proto.Message)
func (*Notification) XXX_Size ¶
func (m *Notification) XXX_Size() int
func (*Notification) XXX_Unmarshal ¶
func (m *Notification) XXX_Unmarshal(b []byte) error
type NotificationServiceClient ¶
type NotificationServiceClient interface {
SendNotification(ctx context.Context, in *SendNotificationRequest, opts ...grpc.CallOption) (*SendNotificationResponse, error)
}
NotificationServiceClient is the client API for NotificationService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNotificationServiceClient ¶
func NewNotificationServiceClient(cc *grpc.ClientConn) NotificationServiceClient
type NotificationServiceServer ¶
type NotificationServiceServer interface {
SendNotification(context.Context, *SendNotificationRequest) (*SendNotificationResponse, error)
}
NotificationServiceServer is the server API for NotificationService service.
type SendNotificationRequest ¶
type SendNotificationRequest struct { Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` Topic string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"` Body string `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendNotificationRequest) Descriptor ¶
func (*SendNotificationRequest) Descriptor() ([]byte, []int)
func (*SendNotificationRequest) GetBody ¶
func (m *SendNotificationRequest) GetBody() string
func (*SendNotificationRequest) GetService ¶
func (m *SendNotificationRequest) GetService() string
func (*SendNotificationRequest) GetTopic ¶
func (m *SendNotificationRequest) GetTopic() string
func (*SendNotificationRequest) ProtoMessage ¶
func (*SendNotificationRequest) ProtoMessage()
func (*SendNotificationRequest) Reset ¶
func (m *SendNotificationRequest) Reset()
func (*SendNotificationRequest) String ¶
func (m *SendNotificationRequest) String() string
func (*SendNotificationRequest) XXX_DiscardUnknown ¶
func (m *SendNotificationRequest) XXX_DiscardUnknown()
func (*SendNotificationRequest) XXX_Marshal ¶
func (m *SendNotificationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendNotificationRequest) XXX_Merge ¶
func (m *SendNotificationRequest) XXX_Merge(src proto.Message)
func (*SendNotificationRequest) XXX_Size ¶
func (m *SendNotificationRequest) XXX_Size() int
func (*SendNotificationRequest) XXX_Unmarshal ¶
func (m *SendNotificationRequest) XXX_Unmarshal(b []byte) error
type SendNotificationResponse ¶
type SendNotificationResponse struct { Notification *Notification `protobuf:"bytes,1,opt,name=notification,proto3" json:"notification,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*SendNotificationResponse) Descriptor ¶
func (*SendNotificationResponse) Descriptor() ([]byte, []int)
func (*SendNotificationResponse) GetNotification ¶
func (m *SendNotificationResponse) GetNotification() *Notification
func (*SendNotificationResponse) ProtoMessage ¶
func (*SendNotificationResponse) ProtoMessage()
func (*SendNotificationResponse) Reset ¶
func (m *SendNotificationResponse) Reset()
func (*SendNotificationResponse) String ¶
func (m *SendNotificationResponse) String() string
func (*SendNotificationResponse) XXX_DiscardUnknown ¶
func (m *SendNotificationResponse) XXX_DiscardUnknown()
func (*SendNotificationResponse) XXX_Marshal ¶
func (m *SendNotificationResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SendNotificationResponse) XXX_Merge ¶
func (m *SendNotificationResponse) XXX_Merge(src proto.Message)
func (*SendNotificationResponse) XXX_Size ¶
func (m *SendNotificationResponse) XXX_Size() int
func (*SendNotificationResponse) XXX_Unmarshal ¶
func (m *SendNotificationResponse) XXX_Unmarshal(b []byte) error
type UnimplementedNotificationServiceServer ¶
type UnimplementedNotificationServiceServer struct { }
UnimplementedNotificationServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedNotificationServiceServer) SendNotification ¶
func (*UnimplementedNotificationServiceServer) SendNotification(ctx context.Context, req *SendNotificationRequest) (*SendNotificationResponse, error)
Click to show internal directories.
Click to hide internal directories.