services

package
v0.0.0-...-893f904 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_api_did_mediator_services_mediator_proto protoreflect.FileDescriptor
View Source 
var MediatorController_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.did.mediator.services.MediatorController",
	HandlerType: (*MediatorControllerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "register",
			Handler:    _MediatorController_Register_Handler,
		},
		{
			MethodName: "unregister",
			Handler:    _MediatorController_Unregister_Handler,
		},
		{
			MethodName: "connections",
			Handler:    _MediatorController_Connections_Handler,
		},
		{
			MethodName: "reconnect",
			Handler:    _MediatorController_Reconnect_Handler,
		},
		{
			MethodName: "status",
			Handler:    _MediatorController_Status_Handler,
		},
		{
			MethodName: "batchPickup",
			Handler:    _MediatorController_BatchPickup_Handler,
		},
		{
			MethodName: "reconnectAll",
			Handler:    _MediatorController_ReconnectAll_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/did/mediator/services/mediator.proto",
}

MediatorController_ServiceDesc is the grpc.ServiceDesc for MediatorController service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterMediatorControllerServer 

func RegisterMediatorControllerServer(s grpc.ServiceRegistrar, srv MediatorControllerServer)

Types

type BatchPickupRequest 

type BatchPickupRequest struct {

	// ConnectionID of connection for which pending messages needs to be dispatched.
	Connection_ID string `protobuf:"bytes,1,opt,name=connection_ID,json=connectionID,proto3" json:"connection_ID,omitempty"`
	// Size of batch of pending messages to be dispatched.
	BatchSize int64 `protobuf:"varint,2,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
	// contains filtered or unexported fields
}

BatchPickupRequest is request for dispatching pending messages.

func (*BatchPickupRequest) Descriptor deprecated 

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

Deprecated: Use BatchPickupRequest.ProtoReflect.Descriptor instead.

func (*BatchPickupRequest) GetBatchSize 

func (x *BatchPickupRequest) GetBatchSize() int64

func (*BatchPickupRequest) GetConnection_ID 

func (x *BatchPickupRequest) GetConnection_ID() string

func (*BatchPickupRequest) ProtoMessage 

func (*BatchPickupRequest) ProtoMessage()

func (*BatchPickupRequest) ProtoReflect 

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

func (*BatchPickupRequest) Reset 

func (x *BatchPickupRequest) Reset()

func (*BatchPickupRequest) String 

func (x *BatchPickupRequest) String() string

type BatchPickupResponse 

type BatchPickupResponse struct {

	// Count of messages dispatched.
	MessageCount int64 `protobuf:"varint,1,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	// contains filtered or unexported fields
}

BatchPickupResponse is response for dispatching pending messages.

func (*BatchPickupResponse) Descriptor deprecated 

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

Deprecated: Use BatchPickupResponse.ProtoReflect.Descriptor instead.

func (*BatchPickupResponse) GetMessageCount 

func (x *BatchPickupResponse) GetMessageCount() int64

func (*BatchPickupResponse) ProtoMessage 

func (*BatchPickupResponse) ProtoMessage()

func (*BatchPickupResponse) ProtoReflect 

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

func (*BatchPickupResponse) Reset 

func (x *BatchPickupResponse) Reset()

func (*BatchPickupResponse) String 

func (x *BatchPickupResponse) String() string

type ConnectionsReq 

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

ConnectionsReq

func (*ConnectionsReq) Descriptor deprecated 

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

Deprecated: Use ConnectionsReq.ProtoReflect.Descriptor instead.

func (*ConnectionsReq) ProtoMessage 

func (*ConnectionsReq) ProtoMessage()

func (*ConnectionsReq) ProtoReflect 

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

func (*ConnectionsReq) Reset 

func (x *ConnectionsReq) Reset()

func (*ConnectionsReq) String 

func (x *ConnectionsReq) String() string

type ConnectionsResponse 

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

ConnectionsResponse is response for router`s connections.

func (*ConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ConnectionsResponse) GetConnections 

func (x *ConnectionsResponse) GetConnections() []string

func (*ConnectionsResponse) ProtoMessage 

func (*ConnectionsResponse) ProtoMessage()

func (*ConnectionsResponse) ProtoReflect 

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

func (*ConnectionsResponse) Reset 

func (x *ConnectionsResponse) Reset()

func (*ConnectionsResponse) String 

func (x *ConnectionsResponse) String() string

type CreateInvitationRequest 

type CreateInvitationRequest struct {
	Label     string       `protobuf:"bytes,1,opt,name=label,proto3" json:"label,omitempty"`
	Goal      string       `protobuf:"bytes,2,opt,name=goal,proto3" json:"goal,omitempty"`
	GoalCode  string       `protobuf:"bytes,3,opt,name=goal_code,json=goalCode,proto3" json:"goal_code,omitempty"`
	Service   []*anypb.Any `protobuf:"bytes,4,rep,name=service,proto3" json:"service,omitempty"`
	Protocols []string     `protobuf:"bytes,5,rep,name=protocols,proto3" json:"protocols,omitempty"`
	// contains filtered or unexported fields
}

CreateInvitationRequest model

This is used for creating an invitation using mediator.

func (*CreateInvitationRequest) Descriptor deprecated 

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

Deprecated: Use CreateInvitationRequest.ProtoReflect.Descriptor instead.

func (*CreateInvitationRequest) GetGoal 

func (x *CreateInvitationRequest) GetGoal() string

func (*CreateInvitationRequest) GetGoalCode 

func (x *CreateInvitationRequest) GetGoalCode() string

func (*CreateInvitationRequest) GetLabel 

func (x *CreateInvitationRequest) GetLabel() string

func (*CreateInvitationRequest) GetProtocols 

func (x *CreateInvitationRequest) GetProtocols() []string

func (*CreateInvitationRequest) GetService 

func (x *CreateInvitationRequest) GetService() []*anypb.Any

func (*CreateInvitationRequest) ProtoMessage 

func (*CreateInvitationRequest) ProtoMessage()

func (*CreateInvitationRequest) ProtoReflect 

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

func (*CreateInvitationRequest) Reset 

func (x *CreateInvitationRequest) Reset()

func (*CreateInvitationRequest) String 

func (x *CreateInvitationRequest) String() string

type CreateInvitationResponse 

type CreateInvitationResponse struct {

	// Invitation is out-of-band invitation from mediator.
	Invitation *types.Invitation `protobuf:"bytes,1,opt,name=invitation,proto3" json:"invitation,omitempty"`
	// contains filtered or unexported fields
}

CreateInvitationResponse model

Response for creating invitation through mediator.

func (*CreateInvitationResponse) Descriptor deprecated 

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

Deprecated: Use CreateInvitationResponse.ProtoReflect.Descriptor instead.

func (*CreateInvitationResponse) GetInvitation 

func (x *CreateInvitationResponse) GetInvitation() *types.Invitation

func (*CreateInvitationResponse) ProtoMessage 

func (*CreateInvitationResponse) ProtoMessage()

func (*CreateInvitationResponse) ProtoReflect 

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

func (*CreateInvitationResponse) Reset 

func (x *CreateInvitationResponse) Reset()

func (*CreateInvitationResponse) String 

func (x *CreateInvitationResponse) String() string

type DocBatchPickupRequest 

type DocBatchPickupRequest struct {

	// Params for dispatching pending messages for given connection..
	//
	// in: body
	Params *BatchPickupRequest `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

docBatchPickupRequest model

For dispatching pending messages for given connection.

swagger:parameters batchPickupRequest

func (*DocBatchPickupRequest) Descriptor deprecated 

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

Deprecated: Use DocBatchPickupRequest.ProtoReflect.Descriptor instead.

func (*DocBatchPickupRequest) GetParams 

func (x *DocBatchPickupRequest) GetParams() *BatchPickupRequest

func (*DocBatchPickupRequest) ProtoMessage 

func (*DocBatchPickupRequest) ProtoMessage()

func (*DocBatchPickupRequest) ProtoReflect 

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

func (*DocBatchPickupRequest) Reset 

func (x *DocBatchPickupRequest) Reset()

func (*DocBatchPickupRequest) String 

func (x *DocBatchPickupRequest) String() string

type DocBatchPickupResponse 

type DocBatchPickupResponse struct {

	// Response after dispatching pending messages for given connection...
	//
	// in: body
	Body *BatchPickupResponse `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

docBatchPickupResponse model

Response from router after pending messages dispatched for given connection.

swagger:response batchPickupResponse

func (*DocBatchPickupResponse) Descriptor deprecated 

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

Deprecated: Use DocBatchPickupResponse.ProtoReflect.Descriptor instead.

func (*DocBatchPickupResponse) GetBody 

func (x *DocBatchPickupResponse) GetBody() *BatchPickupResponse

func (*DocBatchPickupResponse) ProtoMessage 

func (*DocBatchPickupResponse) ProtoMessage()

func (*DocBatchPickupResponse) ProtoReflect 

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

func (*DocBatchPickupResponse) Reset 

func (x *DocBatchPickupResponse) Reset()

func (*DocBatchPickupResponse) String 

func (x *DocBatchPickupResponse) String() string

type DocConnectionsResponse 

type DocConnectionsResponse struct {

	// in: body
	Params *ConnectionsResponse `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

docConnectionsResponse model

Represents a Connections response message

swagger:response getConnectionsResponse

func (*DocConnectionsResponse) Descriptor deprecated 

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

Deprecated: Use DocConnectionsResponse.ProtoReflect.Descriptor instead.

func (*DocConnectionsResponse) GetParams 

func (x *DocConnectionsResponse) GetParams() *ConnectionsResponse

func (*DocConnectionsResponse) ProtoMessage 

func (*DocConnectionsResponse) ProtoMessage()

func (*DocConnectionsResponse) ProtoReflect 

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

func (*DocConnectionsResponse) Reset 

func (x *DocConnectionsResponse) Reset()

func (*DocConnectionsResponse) String 

func (x *DocConnectionsResponse) String() string

type DocStatusRequest 

type DocStatusRequest struct {

	// Params for getting details of pending messages for given connection.
	//
	// in: body
	Params *StatusRequest `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

docStatusRequest model

This is used for getting details of pending messages for given connection.

swagger:parameters statusRequest

func (*DocStatusRequest) Descriptor deprecated 

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

Deprecated: Use DocStatusRequest.ProtoReflect.Descriptor instead.

func (*DocStatusRequest) GetParams 

func (x *DocStatusRequest) GetParams() *StatusRequest

func (*DocStatusRequest) ProtoMessage 

func (*DocStatusRequest) ProtoMessage()

func (*DocStatusRequest) ProtoReflect 

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

func (*DocStatusRequest) Reset 

func (x *DocStatusRequest) Reset()

func (*DocStatusRequest) String 

func (x *DocStatusRequest) String() string

type DocStatusResponse 

type DocStatusResponse struct {

	// Details of pending messages for given connection.
	//
	// in: body
	Body *StatusResponse `protobuf:"bytes,1,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

docStatusResponse model

Response containing details of pending messages for given connection.

swagger:response statusResponse

func (*DocStatusResponse) Descriptor deprecated 

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

Deprecated: Use DocStatusResponse.ProtoReflect.Descriptor instead.

func (*DocStatusResponse) GetBody 

func (x *DocStatusResponse) GetBody() *StatusResponse

func (*DocStatusResponse) ProtoMessage 

func (*DocStatusResponse) ProtoMessage()

func (*DocStatusResponse) ProtoReflect 

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

func (*DocStatusResponse) Reset 

func (x *DocStatusResponse) Reset()

func (*DocStatusResponse) String 

func (x *DocStatusResponse) String() string

type MediatorControllerClient 

type MediatorControllerClient interface {
	// Register swagger:route POST /mediator/register mediator registerRouteRequest
	//
	// Registers the agent with the router.
	//
	// Responses:
	//    default: genericError
	//    200: registerRouteRes
	Register(ctx context.Context, in *RegisterRouteReq, opts ...grpc.CallOption) (*RegisterRouteRes, error)
	// Unregister swagger:route DELETE /mediator/unregister mediator unregisterRouter
	//
	// Unregisters the agent with the router.
	//
	// Responses:
	//    default: genericError
	//    200: unregisterRouteRes
	Unregister(ctx context.Context, in *UnregisterRouterReq, opts ...grpc.CallOption) (*UnregisterRouteRes, error)
	// Connections swagger:route GET /mediator/connections mediator connectionsRequest
	//
	// Retrieves the router`s connections.
	//
	// Responses:
	//    default: genericError
	//    200: getConnectionsResponse
	Connections(ctx context.Context, in *ConnectionsReq, opts ...grpc.CallOption) (*ConnectionsResponse, error)
	// Reconnect swagger:route POST /mediator/reconnect mediator reconnectRouteRequest
	//
	// Reconnect the agent with the router to re-establish lost connection.
	//
	// Responses:
	//    default: genericError
	Reconnect(ctx context.Context, in *ReconnectRouteReq, opts ...grpc.CallOption) (*ReconnectRouteRes, error)
	// Status swagger:route POST /mediator/status mediator statusRequest
	//
	// Status returns details about pending messages for given connection.
	//
	// Responses:
	//    default: genericError
	//    200: statusResponse
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// BatchPickup swagger:route POST /mediator/batchpickup mediator batchPickupRequest
	//
	// BatchPickup dispatches pending messages for given connection.
	//
	// Responses:
	//    default: genericError
	//    200: batchPickupResponse
	BatchPickup(ctx context.Context, in *BatchPickupRequest, opts ...grpc.CallOption) (*BatchPickupResponse, error)
	// ReconnectAll swagger:route GET /mediator/reconnect-all mediator reconnectAll
	//
	// Re-establishes network connections for all mediator connections.
	//
	// Responses:
	//    default: genericError
	ReconnectAll(ctx context.Context, in *ReconnectRouteReq, opts ...grpc.CallOption) (*ReconnectRouteRes, error)
}

MediatorControllerClient is the client API for MediatorController service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewMediatorControllerClient 

func NewMediatorControllerClient(cc grpc.ClientConnInterface) MediatorControllerClient

type MediatorControllerServer 

type MediatorControllerServer interface {
	// Register swagger:route POST /mediator/register mediator registerRouteRequest
	//
	// Registers the agent with the router.
	//
	// Responses:
	//    default: genericError
	//    200: registerRouteRes
	Register(context.Context, *RegisterRouteReq) (*RegisterRouteRes, error)
	// Unregister swagger:route DELETE /mediator/unregister mediator unregisterRouter
	//
	// Unregisters the agent with the router.
	//
	// Responses:
	//    default: genericError
	//    200: unregisterRouteRes
	Unregister(context.Context, *UnregisterRouterReq) (*UnregisterRouteRes, error)
	// Connections swagger:route GET /mediator/connections mediator connectionsRequest
	//
	// Retrieves the router`s connections.
	//
	// Responses:
	//    default: genericError
	//    200: getConnectionsResponse
	Connections(context.Context, *ConnectionsReq) (*ConnectionsResponse, error)
	// Reconnect swagger:route POST /mediator/reconnect mediator reconnectRouteRequest
	//
	// Reconnect the agent with the router to re-establish lost connection.
	//
	// Responses:
	//    default: genericError
	Reconnect(context.Context, *ReconnectRouteReq) (*ReconnectRouteRes, error)
	// Status swagger:route POST /mediator/status mediator statusRequest
	//
	// Status returns details about pending messages for given connection.
	//
	// Responses:
	//    default: genericError
	//    200: statusResponse
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// BatchPickup swagger:route POST /mediator/batchpickup mediator batchPickupRequest
	//
	// BatchPickup dispatches pending messages for given connection.
	//
	// Responses:
	//    default: genericError
	//    200: batchPickupResponse
	BatchPickup(context.Context, *BatchPickupRequest) (*BatchPickupResponse, error)
	// ReconnectAll swagger:route GET /mediator/reconnect-all mediator reconnectAll
	//
	// Re-establishes network connections for all mediator connections.
	//
	// Responses:
	//    default: genericError
	ReconnectAll(context.Context, *ReconnectRouteReq) (*ReconnectRouteRes, error)
	// contains filtered or unexported methods
}

MediatorControllerServer is the server API for MediatorController service. All implementations must embed UnimplementedMediatorControllerServer for forward compatibility

type ReconnectRouteReq 

type ReconnectRouteReq struct {

	// Params for reconnecting the router
	//
	// in: body
	Params *RegisterRoute `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

reconnectRouteReq model

This is used register router for the agent.

swagger:parameters reconnectRouteRequest

func (*ReconnectRouteReq) Descriptor deprecated 

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

Deprecated: Use ReconnectRouteReq.ProtoReflect.Descriptor instead.

func (*ReconnectRouteReq) GetParams 

func (x *ReconnectRouteReq) GetParams() *RegisterRoute

func (*ReconnectRouteReq) ProtoMessage 

func (*ReconnectRouteReq) ProtoMessage()

func (*ReconnectRouteReq) ProtoReflect 

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

func (*ReconnectRouteReq) Reset 

func (x *ReconnectRouteReq) Reset()

func (*ReconnectRouteReq) String 

func (x *ReconnectRouteReq) String() string

type ReconnectRouteRes 

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

func (*ReconnectRouteRes) Descriptor deprecated 

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

Deprecated: Use ReconnectRouteRes.ProtoReflect.Descriptor instead.

func (*ReconnectRouteRes) ProtoMessage 

func (*ReconnectRouteRes) ProtoMessage()

func (*ReconnectRouteRes) ProtoReflect 

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

func (*ReconnectRouteRes) Reset 

func (x *ReconnectRouteRes) Reset()

func (*ReconnectRouteRes) String 

func (x *ReconnectRouteRes) String() string

type RegisterRoute 

type RegisterRoute struct {
	Connection_ID string `protobuf:"bytes,1,opt,name=connection_ID,json=connectionID,proto3" json:"connection_ID,omitempty"`
	// contains filtered or unexported fields
}

RegisterRoute contains parameters for registering/reconnecting router.

func (*RegisterRoute) Descriptor deprecated 

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

Deprecated: Use RegisterRoute.ProtoReflect.Descriptor instead.

func (*RegisterRoute) GetConnection_ID 

func (x *RegisterRoute) GetConnection_ID() string

func (*RegisterRoute) ProtoMessage 

func (*RegisterRoute) ProtoMessage()

func (*RegisterRoute) ProtoReflect 

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

func (*RegisterRoute) Reset 

func (x *RegisterRoute) Reset()

func (*RegisterRoute) String 

func (x *RegisterRoute) String() string

type RegisterRouteReq 

type RegisterRouteReq struct {

	// Params for registering the route
	//
	// in: body
	Params *RegisterRoute `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

RegisterRouteReq model

This is used register router for the agent.

swagger:parameters registerRouteRequest

func (*RegisterRouteReq) Descriptor deprecated 

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

Deprecated: Use RegisterRouteReq.ProtoReflect.Descriptor instead.

func (*RegisterRouteReq) GetParams 

func (x *RegisterRouteReq) GetParams() *RegisterRoute

func (*RegisterRouteReq) ProtoMessage 

func (*RegisterRouteReq) ProtoMessage()

func (*RegisterRouteReq) ProtoReflect 

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

func (*RegisterRouteReq) Reset 

func (x *RegisterRouteReq) Reset()

func (*RegisterRouteReq) String 

func (x *RegisterRouteReq) String() string

type RegisterRouteRes 

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

RegisterRouteRes model

swagger:response registerRouteRes

func (*RegisterRouteRes) Descriptor deprecated 

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

Deprecated: Use RegisterRouteRes.ProtoReflect.Descriptor instead.

func (*RegisterRouteRes) ProtoMessage 

func (*RegisterRouteRes) ProtoMessage()

func (*RegisterRouteRes) ProtoReflect 

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

func (*RegisterRouteRes) Reset 

func (x *RegisterRouteRes) Reset()

func (*RegisterRouteRes) String 

func (x *RegisterRouteRes) String() string

type StatusRequest 

type StatusRequest struct {
	Connection_ID string `protobuf:"bytes,1,opt,name=connection_ID,json=connectionID,proto3" json:"connection_ID,omitempty"`
	// contains filtered or unexported fields
}

StatusRequest is request for getting details about pending messages.

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetConnection_ID 

func (x *StatusRequest) GetConnection_ID() string

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Id                string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`     // @id
	Type              string                 `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` // @type
	MessageCount      int32                  `protobuf:"varint,3,opt,name=message_count,json=messageCount,proto3" json:"message_count,omitempty"`
	DurationWaited    int32                  `protobuf:"varint,4,opt,name=duration_waited,json=durationWaited,proto3" json:"duration_waited,omitempty"`
	LastAddedTime     *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_added_time,json=lastAddedTime,proto3" json:"last_added_time,omitempty"`
	LastDeliveredTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_delivered_time,json=lastDeliveredTime,proto3" json:"last_delivered_time,omitempty"`
	LastRemovedTime   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=last_removed_time,json=lastRemovedTime,proto3" json:"last_removed_time,omitempty"`
	TotalSize         int32                  `protobuf:"varint,8,opt,name=total_size,json=totalSize,proto3" json:"total_size,omitempty"`
	Thread            *types.Thread          `protobuf:"bytes,9,opt,name=thread,proto3" json:"thread,omitempty"` // ~thread
	// contains filtered or unexported fields
}

StatusResponse is status response containing details about pending messages.

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetDurationWaited 

func (x *StatusResponse) GetDurationWaited() int32

func (*StatusResponse) GetId 

func (x *StatusResponse) GetId() string

func (*StatusResponse) GetLastAddedTime 

func (x *StatusResponse) GetLastAddedTime() *timestamppb.Timestamp

func (*StatusResponse) GetLastDeliveredTime 

func (x *StatusResponse) GetLastDeliveredTime() *timestamppb.Timestamp

func (*StatusResponse) GetLastRemovedTime 

func (x *StatusResponse) GetLastRemovedTime() *timestamppb.Timestamp

func (*StatusResponse) GetMessageCount 

func (x *StatusResponse) GetMessageCount() int32

func (*StatusResponse) GetThread 

func (x *StatusResponse) GetThread() *types.Thread

func (*StatusResponse) GetTotalSize 

func (x *StatusResponse) GetTotalSize() int32

func (*StatusResponse) GetType 

func (x *StatusResponse) GetType() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type UnimplementedMediatorControllerServer 

type UnimplementedMediatorControllerServer struct {
}

UnimplementedMediatorControllerServer must be embedded to have forward compatible implementations.

func (UnimplementedMediatorControllerServer) BatchPickup 

func (UnimplementedMediatorControllerServer) BatchPickup(context.Context, *BatchPickupRequest) (*BatchPickupResponse, error)

func (UnimplementedMediatorControllerServer) Connections 

func (UnimplementedMediatorControllerServer) Connections(context.Context, *ConnectionsReq) (*ConnectionsResponse, error)

func (UnimplementedMediatorControllerServer) Reconnect 

func (UnimplementedMediatorControllerServer) Reconnect(context.Context, *ReconnectRouteReq) (*ReconnectRouteRes, error)

func (UnimplementedMediatorControllerServer) ReconnectAll 

func (UnimplementedMediatorControllerServer) ReconnectAll(context.Context, *ReconnectRouteReq) (*ReconnectRouteRes, error)

func (UnimplementedMediatorControllerServer) Register 

func (UnimplementedMediatorControllerServer) Register(context.Context, *RegisterRouteReq) (*RegisterRouteRes, error)

func (UnimplementedMediatorControllerServer) Status 

func (UnimplementedMediatorControllerServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

func (UnimplementedMediatorControllerServer) Unregister 

func (UnimplementedMediatorControllerServer) Unregister(context.Context, *UnregisterRouterReq) (*UnregisterRouteRes, error)

type UnregisterRouteRes 

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

UnregisterRouteRes model

swagger:response unregisterRouteRes

func (*UnregisterRouteRes) Descriptor deprecated 

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

Deprecated: Use UnregisterRouteRes.ProtoReflect.Descriptor instead.

func (*UnregisterRouteRes) ProtoMessage 

func (*UnregisterRouteRes) ProtoMessage()

func (*UnregisterRouteRes) ProtoReflect 

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

func (*UnregisterRouteRes) Reset 

func (x *UnregisterRouteRes) Reset()

func (*UnregisterRouteRes) String 

func (x *UnregisterRouteRes) String() string

type UnregisterRouterReq 

type UnregisterRouterReq struct {

	// Params for unregister the router
	//
	// in: body
	Params *RegisterRoute `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

UnregisterRouterReq model

This is used for unregister a router for the agent.

swagger:parameters unregisterRouter

func (*UnregisterRouterReq) Descriptor deprecated 

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

Deprecated: Use UnregisterRouterReq.ProtoReflect.Descriptor instead.

func (*UnregisterRouterReq) GetParams 

func (x *UnregisterRouterReq) GetParams() *RegisterRoute

func (*UnregisterRouterReq) ProtoMessage 

func (*UnregisterRouterReq) ProtoMessage()

func (*UnregisterRouterReq) ProtoReflect 

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

func (*UnregisterRouterReq) Reset 

func (x *UnregisterRouterReq) Reset()

func (*UnregisterRouterReq) String 

func (x *UnregisterRouterReq) String() string

type UnsafeMediatorControllerServer 

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

UnsafeMediatorControllerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MediatorControllerServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.