websocketspb

type ClientMessage struct {

	// Globally unique id to pair requests/responses
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ClientMessage_RegistrationRequest
	//	*ClientMessage_WebsocketEventResponse
	Content isClientMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ClientMessage_RegistrationRequest struct {
	// Client initialisation request
	// A worker will not be eligible for triggers
	// until it has identified itself
	RegistrationRequest *RegistrationRequest `protobuf:"bytes,2,opt,name=registration_request,json=registrationRequest,proto3,oneof"`
}

type ClientMessage_WebsocketEventResponse struct {
	// Client responding with result of a trigger
	WebsocketEventResponse *WebsocketEventResponse `protobuf:"bytes,3,opt,name=websocket_event_response,json=websocketEventResponse,proto3,oneof"`
}

type QueryValue struct {
	Value []string `protobuf:"bytes,1,rep,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

type RegistrationRequest struct {

	// The nitric name of the socket that this worker listens on
	SocketName string `protobuf:"bytes,1,opt,name=socket_name,json=socketName,proto3" json:"socket_name,omitempty"`
	// The type of event that this worker handles
	EventType WebsocketEventType `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

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

type ServerMessage struct {

	// Server message ID, used to pair requests/responses
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Types that are assignable to Content:
	//
	//	*ServerMessage_RegistrationResponse
	//	*ServerMessage_WebsocketEventRequest
	Content isServerMessage_Content `protobuf_oneof:"content"`
	// contains filtered or unexported fields
}

type ServerMessage_RegistrationResponse struct {
	// Server responding
	// with client configuration details to an
	// InitRequest
	RegistrationResponse *RegistrationResponse `protobuf:"bytes,2,opt,name=registration_response,json=registrationResponse,proto3,oneof"`
}

type ServerMessage_WebsocketEventRequest struct {
	// Server requesting client to process an event
	WebsocketEventRequest *WebsocketEventRequest `protobuf:"bytes,3,opt,name=websocket_event_request,json=websocketEventRequest,proto3,oneof"`
}

type UnimplementedWebsocketHandlerServer struct {
}

type UnimplementedWebsocketServer struct {
}

type UnsafeWebsocketHandlerServer interface {
	// contains filtered or unexported methods
}

type UnsafeWebsocketServer interface {
	// contains filtered or unexported methods
}

type WebsocketClient interface {
	// Send a messages to a websocket
	SendMessage(ctx context.Context, in *WebsocketSendRequest, opts ...grpc.CallOption) (*WebsocketSendResponse, error)
	// Close a websocket connection
	// This can be used to force a client to disconnect
	CloseConnection(ctx context.Context, in *WebsocketCloseConnectionRequest, opts ...grpc.CallOption) (*WebsocketCloseConnectionResponse, error)
	// Retrieve details about an API
	SocketDetails(ctx context.Context, in *WebsocketDetailsRequest, opts ...grpc.CallOption) (*WebsocketDetailsResponse, error)
}

type WebsocketCloseConnectionRequest struct {

	// The nitric name of the socket to send on
	SocketName string `protobuf:"bytes,1,opt,name=socket_name,json=socketName,proto3" json:"socket_name,omitempty"`
	// The connection ID of the client to send to
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// contains filtered or unexported fields
}

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

type WebsocketConnectionEvent struct {

	// The query params available in the connection request
	QueryParams map[string]*QueryValue `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

type WebsocketConnectionResponse struct {
	Reject bool `protobuf:"varint,1,opt,name=reject,proto3" json:"reject,omitempty"`
	// contains filtered or unexported fields
}

type WebsocketDetailsRequest struct {
	SocketName string `protobuf:"bytes,1,opt,name=socket_name,json=socketName,proto3" json:"socket_name,omitempty"`
	// contains filtered or unexported fields
}

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

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

type WebsocketEventRequest struct {

	// The nitric name of the socket that this worker listens on
	SocketName string `protobuf:"bytes,1,opt,name=socket_name,json=socketName,proto3" json:"socket_name,omitempty"`
	// The connection this trigger came from
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// Types that are assignable to WebsocketEvent:
	//
	//	*WebsocketEventRequest_Connection
	//	*WebsocketEventRequest_Disconnection
	//	*WebsocketEventRequest_Message
	WebsocketEvent isWebsocketEventRequest_WebsocketEvent `protobuf_oneof:"websocket_event"`
	// contains filtered or unexported fields
}

type WebsocketEventRequest_Connection struct {
	Connection *WebsocketConnectionEvent `protobuf:"bytes,10,opt,name=connection,proto3,oneof"`
}

type WebsocketEventRequest_Disconnection struct {
	Disconnection *WebsocketDisconnectionEvent `protobuf:"bytes,11,opt,name=disconnection,proto3,oneof"`
}

type WebsocketEventRequest_Message struct {
	Message *WebsocketMessageEvent `protobuf:"bytes,12,opt,name=message,proto3,oneof"`
}

type WebsocketEventResponse struct {

	// Types that are assignable to WebsocketResponse:
	//
	//	*WebsocketEventResponse_ConnectionResponse
	WebsocketResponse isWebsocketEventResponse_WebsocketResponse `protobuf_oneof:"websocket_response"`
	// contains filtered or unexported fields
}

type WebsocketEventResponse_ConnectionResponse struct {
	ConnectionResponse *WebsocketConnectionResponse `protobuf:"bytes,10,opt,name=connection_response,json=connectionResponse,proto3,oneof"`
}

type WebsocketEventType int32

type WebsocketHandlerClient interface {
	// Handle incoming websocket events
	HandleEvents(ctx context.Context, opts ...grpc.CallOption) (WebsocketHandler_HandleEventsClient, error)
}

type WebsocketHandlerServer interface {
	// Handle incoming websocket events
	HandleEvents(WebsocketHandler_HandleEventsServer) error
}

type WebsocketHandler_HandleEventsClient interface {
	Send(*ClientMessage) error
	Recv() (*ServerMessage, error)
	grpc.ClientStream
}

type WebsocketHandler_HandleEventsServer interface {
	Send(*ServerMessage) error
	Recv() (*ClientMessage, error)
	grpc.ServerStream
}

type WebsocketMessageEvent struct {

	// Data available on
	Body []byte `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

type WebsocketSendRequest struct {

	// The nitric name of the socket to send on
	SocketName string `protobuf:"bytes,1,opt,name=socket_name,json=socketName,proto3" json:"socket_name,omitempty"`
	// The connection ID of the client to send to
	ConnectionId string `protobuf:"bytes,2,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	// The data to send to the socket
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

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

type WebsocketServer interface {
	// Send a messages to a websocket
	SendMessage(context.Context, *WebsocketSendRequest) (*WebsocketSendResponse, error)
	// Close a websocket connection
	// This can be used to force a client to disconnect
	CloseConnection(context.Context, *WebsocketCloseConnectionRequest) (*WebsocketCloseConnectionResponse, error)
	// Retrieve details about an API
	SocketDetails(context.Context, *WebsocketDetailsRequest) (*WebsocketDetailsResponse, error)
}