readynotify

Documentation

Index

• Variables
• func RegisterReadyNotifyServer(s *grpc.Server, srv ReadyNotifyServer)
• type Alert
  • func (*Alert) Descriptor() ([]byte, []int)
  • func (x *Alert) GetMessage() string
  • func (*Alert) ProtoMessage()
  • func (x *Alert) ProtoReflect() protoreflect.Message
  • func (x *Alert) Reset()
  • func (x *Alert) String() string
• type Notification
  • func (*Notification) Descriptor() ([]byte, []int)
  • func (x *Notification) GetApp() string
  • func (x *Notification) GetAppContext() string
  • func (x *Notification) GetClientName() string
  • func (x *Notification) GetCluster() string
  • func (x *Notification) GetServerName() string
  • func (*Notification) ProtoMessage()
  • func (x *Notification) ProtoReflect() protoreflect.Message
  • func (x *Notification) Reset()
  • func (x *Notification) String() string
• type ReadyNotifyClient
  • func NewReadyNotifyClient(cc grpc.ClientConnInterface) ReadyNotifyClient
• type ReadyNotifyServer
• type ReadyNotify_AlertClient
• type ReadyNotify_AlertServer
• type Topic
  • func (*Topic) Descriptor() ([]byte, []int)
  • func (x *Topic) GetAppContext() string
  • func (x *Topic) GetClientName() string
  • func (*Topic) ProtoMessage()
  • func (x *Topic) ProtoReflect() protoreflect.Message
  • func (x *Topic) Reset()
  • func (x *Topic) String() string
• type UnimplementedReadyNotifyServer
  • func (*UnimplementedReadyNotifyServer) Alert(*Topic, ReadyNotify_AlertServer) error
  • func (*UnimplementedReadyNotifyServer) Unsubscribe(context.Context, *Topic) (*UnsubscribeResponse, error)
• type UnsubscribeResponse
  • func (*UnsubscribeResponse) Descriptor() ([]byte, []int)
  • func (*UnsubscribeResponse) ProtoMessage()
  • func (x *UnsubscribeResponse) ProtoReflect() protoreflect.Message
  • func (x *UnsubscribeResponse) Reset()
  • func (x *UnsubscribeResponse) String() string

Variables

var File_readynotify_proto protoreflect.FileDescriptor

Functions

func RegisterReadyNotifyServer

func RegisterReadyNotifyServer(s *grpc.Server, srv ReadyNotifyServer)

Types

type Alert

type Alert struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*Alert) Descriptor

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

Deprecated: Use Alert.ProtoReflect.Descriptor instead.

func (*Alert) GetMessage

func (x *Alert) GetMessage() string

func (*Alert) ProtoMessage

func (*Alert) ProtoMessage()

func (*Alert) ProtoReflect

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

func (*Alert) Reset

func (x *Alert) Reset()

func (*Alert) String

func (x *Alert) String() string

type Notification

type Notification struct {
	ClientName string `protobuf:"bytes,1,opt,name=clientName,proto3" json:"clientName,omitempty"`
	ServerName string `protobuf:"bytes,2,opt,name=serverName,proto3" json:"serverName,omitempty"`
	AppContext string `protobuf:"bytes,3,opt,name=appContext,proto3" json:"appContext,omitempty"`
	App        string `protobuf:"bytes,4,opt,name=app,proto3" json:"app,omitempty"`
	Cluster    string `protobuf:"bytes,5,opt,name=cluster,proto3" json:"cluster,omitempty"`
	// contains filtered or unexported fields
}

func (*Notification) Descriptor

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

Deprecated: Use Notification.ProtoReflect.Descriptor instead.

func (*Notification) GetApp

func (x *Notification) GetApp() string

func (*Notification) GetAppContext

func (x *Notification) GetAppContext() string

func (*Notification) GetClientName

func (x *Notification) GetClientName() string

func (*Notification) GetCluster

func (x *Notification) GetCluster() string

func (*Notification) GetServerName

func (x *Notification) GetServerName() string

func (*Notification) ProtoMessage

func (*Notification) ProtoMessage()

func (*Notification) ProtoReflect

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

func (*Notification) Reset

func (x *Notification) Reset()

func (*Notification) String

func (x *Notification) String() string

type ReadyNotifyClient

type ReadyNotifyClient interface {
	Alert(ctx context.Context, in *Topic, opts ...grpc.CallOption) (ReadyNotify_AlertClient, error)
	Unsubscribe(ctx context.Context, in *Topic, opts ...grpc.CallOption) (*UnsubscribeResponse, error)
}

ReadyNotifyClient is the client API for ReadyNotify service.

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

func NewReadyNotifyClient

func NewReadyNotifyClient(cc grpc.ClientConnInterface) ReadyNotifyClient

type ReadyNotifyServer

type ReadyNotifyServer interface {
	Alert(*Topic, ReadyNotify_AlertServer) error
	Unsubscribe(context.Context, *Topic) (*UnsubscribeResponse, error)
}

ReadyNotifyServer is the server API for ReadyNotify service.

type ReadyNotify_AlertClient

type ReadyNotify_AlertClient interface {
	Recv() (*Notification, error)
	grpc.ClientStream
}

type ReadyNotify_AlertServer

type ReadyNotify_AlertServer interface {
	Send(*Notification) error
	grpc.ServerStream
}

type Topic

type Topic struct {
	ClientName string `protobuf:"bytes,1,opt,name=clientName,proto3" json:"clientName,omitempty"`
	AppContext string `protobuf:"bytes,2,opt,name=appContext,proto3" json:"appContext,omitempty"`
	// contains filtered or unexported fields
}

func (*Topic) Descriptor

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetAppContext

func (x *Topic) GetAppContext() string

func (*Topic) GetClientName

func (x *Topic) GetClientName() string

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect

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

func (*Topic) Reset

func (x *Topic) Reset()

func (*Topic) String

func (x *Topic) String() string

type UnimplementedReadyNotifyServer

type UnimplementedReadyNotifyServer struct {
}

UnimplementedReadyNotifyServer can be embedded to have forward compatible implementations.

func (*UnimplementedReadyNotifyServer) Alert

func (*UnimplementedReadyNotifyServer) Alert(*Topic, ReadyNotify_AlertServer) error

func (*UnimplementedReadyNotifyServer) Unsubscribe

func (*UnimplementedReadyNotifyServer) Unsubscribe(context.Context, *Topic) (*UnsubscribeResponse, error)

type UnsubscribeResponse

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

func (*UnsubscribeResponse) Descriptor

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

Deprecated: Use UnsubscribeResponse.ProtoReflect.Descriptor instead.

func (*UnsubscribeResponse) ProtoMessage

func (*UnsubscribeResponse) ProtoMessage()

func (*UnsubscribeResponse) ProtoReflect

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

func (*UnsubscribeResponse) Reset

func (x *UnsubscribeResponse) Reset()

func (*UnsubscribeResponse) String

func (x *UnsubscribeResponse) String() string