pb

type NotifierClient ¶

type NotifierClient interface {
	Listen(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
	Notify(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)
}

NotifierClient is the client API for Notifier service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNotifierClient(cc grpc.ClientConnInterface) NotifierClient

type NotifierServer ¶

type NotifierServer interface {
	Listen(context.Context, *Request) (*Response, error)
	Notify(context.Context, *Request) (*Response, error)
}

NotifierServer is the server API for Notifier service.

type Request ¶

type Request struct {
	// contains filtered or unexported fields
}

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

func (*Request) ProtoMessage()

func (x *Request) ProtoReflect() protoreflect.Message

func (x *Request) Reset()

func (x *Request) String() string

type Response ¶

type Response struct {
	// contains filtered or unexported fields
}

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

func (*Response) ProtoMessage()

func (x *Response) ProtoReflect() protoreflect.Message

func (x *Response) Reset()

func (x *Response) String() string

type UnimplementedNotifierServer ¶

type UnimplementedNotifierServer struct {
}

UnimplementedNotifierServer can be embedded to have forward compatible implementations.

func (*UnimplementedNotifierServer) Listen(context.Context, *Request) (*Response, error)

func (*UnimplementedNotifierServer) Notify(context.Context, *Request) (*Response, error)