Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterMediatorAdministrationServiceServer(s grpc.ServiceRegistrar, srv MediatorAdministrationServiceServer)
- func RegisterMediatorInitializationServiceServer(s grpc.ServiceRegistrar, srv MediatorInitializationServiceServer)
- func RegisterSequencerConnectionServiceServer(s grpc.ServiceRegistrar, srv SequencerConnectionServiceServer)
- type GetConnectionRequest
- type GetConnectionResponse
- func (*GetConnectionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetConnectionResponse) GetSequencerConnections() *v30.SequencerConnections
- func (*GetConnectionResponse) ProtoMessage()
- func (x *GetConnectionResponse) ProtoReflect() protoreflect.Message
- func (x *GetConnectionResponse) Reset()
- func (x *GetConnectionResponse) String() string
- type InitializeMediatorRequest
- func (*InitializeMediatorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InitializeMediatorRequest) GetDomainId() string
- func (x *InitializeMediatorRequest) GetSequencerConnectionValidation() v30.SequencerConnectionValidation
- func (x *InitializeMediatorRequest) GetSequencerConnections() *v30.SequencerConnections
- func (*InitializeMediatorRequest) ProtoMessage()
- func (x *InitializeMediatorRequest) ProtoReflect() protoreflect.Message
- func (x *InitializeMediatorRequest) Reset()
- func (x *InitializeMediatorRequest) String() string
- type InitializeMediatorResponse
- type MediatorAdministrationServiceClient
- type MediatorAdministrationServiceServer
- type MediatorInitializationServiceClient
- type MediatorInitializationServiceServer
- type MediatorPruning
- type MediatorPruning_PruneRequest
- func (*MediatorPruning_PruneRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MediatorPruning_PruneRequest) GetTimestamp() *timestamppb.Timestamp
- func (*MediatorPruning_PruneRequest) ProtoMessage()
- func (x *MediatorPruning_PruneRequest) ProtoReflect() protoreflect.Message
- func (x *MediatorPruning_PruneRequest) Reset()
- func (x *MediatorPruning_PruneRequest) String() string
- type MediatorPruning_PruneResponse
- func (*MediatorPruning_PruneResponse) Descriptor() ([]byte, []int)deprecated
- func (*MediatorPruning_PruneResponse) ProtoMessage()
- func (x *MediatorPruning_PruneResponse) ProtoReflect() protoreflect.Message
- func (x *MediatorPruning_PruneResponse) Reset()
- func (x *MediatorPruning_PruneResponse) String() string
- type SequencerConnectionServiceClient
- type SequencerConnectionServiceServer
- type SetConnectionRequest
- func (*SetConnectionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetConnectionRequest) GetSequencerConnectionValidation() v30.SequencerConnectionValidation
- func (x *SetConnectionRequest) GetSequencerConnections() *v30.SequencerConnections
- func (*SetConnectionRequest) ProtoMessage()
- func (x *SetConnectionRequest) ProtoReflect() protoreflect.Message
- func (x *SetConnectionRequest) Reset()
- func (x *SetConnectionRequest) String() string
- type SetConnectionResponse
- type UnimplementedMediatorAdministrationServiceServer
- func (UnimplementedMediatorAdministrationServiceServer) ClearSchedule(context.Context, *v30.ClearSchedule_Request) (*v30.ClearSchedule_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) GetSchedule(context.Context, *v30.GetSchedule_Request) (*v30.GetSchedule_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) LocatePruningTimestamp(context.Context, *v30.LocatePruningTimestamp_Request) (*v30.LocatePruningTimestamp_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) Prune(context.Context, *MediatorPruning_PruneRequest) (*MediatorPruning_PruneResponse, error)
- func (UnimplementedMediatorAdministrationServiceServer) SetCron(context.Context, *v30.SetCron_Request) (*v30.SetCron_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) SetMaxDuration(context.Context, *v30.SetMaxDuration_Request) (*v30.SetMaxDuration_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) SetRetention(context.Context, *v30.SetRetention_Request) (*v30.SetRetention_Response, error)
- func (UnimplementedMediatorAdministrationServiceServer) SetSchedule(context.Context, *v30.SetSchedule_Request) (*v30.SetSchedule_Response, error)
- type UnimplementedMediatorInitializationServiceServer
- type UnimplementedSequencerConnectionServiceServer
- type UnsafeMediatorAdministrationServiceServer
- type UnsafeMediatorInitializationServiceServer
- type UnsafeSequencerConnectionServiceServer
Constants ¶
const ( MediatorAdministrationService_Prune_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/Prune" MediatorAdministrationService_SetSchedule_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/SetSchedule" MediatorAdministrationService_SetCron_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/SetCron" MediatorAdministrationService_SetMaxDuration_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/SetMaxDuration" MediatorAdministrationService_SetRetention_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/SetRetention" MediatorAdministrationService_ClearSchedule_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/ClearSchedule" MediatorAdministrationService_GetSchedule_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/GetSchedule" MediatorAdministrationService_LocatePruningTimestamp_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService/LocatePruningTimestamp" )
const ( SequencerConnectionService_GetConnection_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.SequencerConnectionService/GetConnection" SequencerConnectionService_SetConnection_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.SequencerConnectionService/SetConnection" )
const (
MediatorInitializationService_InitializeMediator_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorInitializationService/InitializeMediator"
)
Variables ¶
var File_com_digitalasset_canton_mediator_admin_v30_mediator_administration_service_proto protoreflect.FileDescriptor
var File_com_digitalasset_canton_mediator_admin_v30_mediator_initialization_service_proto protoreflect.FileDescriptor
var File_com_digitalasset_canton_mediator_admin_v30_sequencer_connection_service_proto protoreflect.FileDescriptor
var MediatorAdministrationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.digitalasset.canton.mediator.admin.v30.MediatorAdministrationService", HandlerType: (*MediatorAdministrationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Prune", Handler: _MediatorAdministrationService_Prune_Handler, }, { MethodName: "SetSchedule", Handler: _MediatorAdministrationService_SetSchedule_Handler, }, { MethodName: "SetCron", Handler: _MediatorAdministrationService_SetCron_Handler, }, { MethodName: "SetMaxDuration", Handler: _MediatorAdministrationService_SetMaxDuration_Handler, }, { MethodName: "SetRetention", Handler: _MediatorAdministrationService_SetRetention_Handler, }, { MethodName: "ClearSchedule", Handler: _MediatorAdministrationService_ClearSchedule_Handler, }, { MethodName: "GetSchedule", Handler: _MediatorAdministrationService_GetSchedule_Handler, }, { MethodName: "LocatePruningTimestamp", Handler: _MediatorAdministrationService_LocatePruningTimestamp_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/digitalasset/canton/mediator/admin/v30/mediator_administration_service.proto", }
MediatorAdministrationService_ServiceDesc is the grpc.ServiceDesc for MediatorAdministrationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var MediatorInitializationService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.digitalasset.canton.mediator.admin.v30.MediatorInitializationService", HandlerType: (*MediatorInitializationServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "InitializeMediator", Handler: _MediatorInitializationService_InitializeMediator_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/digitalasset/canton/mediator/admin/v30/mediator_initialization_service.proto", }
MediatorInitializationService_ServiceDesc is the grpc.ServiceDesc for MediatorInitializationService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SequencerConnectionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "com.digitalasset.canton.mediator.admin.v30.SequencerConnectionService", HandlerType: (*SequencerConnectionServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetConnection", Handler: _SequencerConnectionService_GetConnection_Handler, }, { MethodName: "SetConnection", Handler: _SequencerConnectionService_SetConnection_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "com/digitalasset/canton/mediator/admin/v30/sequencer_connection_service.proto", }
SequencerConnectionService_ServiceDesc is the grpc.ServiceDesc for SequencerConnectionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMediatorAdministrationServiceServer ¶
func RegisterMediatorAdministrationServiceServer(s grpc.ServiceRegistrar, srv MediatorAdministrationServiceServer)
func RegisterMediatorInitializationServiceServer ¶
func RegisterMediatorInitializationServiceServer(s grpc.ServiceRegistrar, srv MediatorInitializationServiceServer)
func RegisterSequencerConnectionServiceServer ¶
func RegisterSequencerConnectionServiceServer(s grpc.ServiceRegistrar, srv SequencerConnectionServiceServer)
Types ¶
type GetConnectionRequest ¶
type GetConnectionRequest struct {
// contains filtered or unexported fields
}
func (*GetConnectionRequest) Descriptor
deprecated
func (*GetConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectionRequest.ProtoReflect.Descriptor instead.
func (*GetConnectionRequest) ProtoMessage ¶
func (*GetConnectionRequest) ProtoMessage()
func (*GetConnectionRequest) ProtoReflect ¶
func (x *GetConnectionRequest) ProtoReflect() protoreflect.Message
func (*GetConnectionRequest) Reset ¶
func (x *GetConnectionRequest) Reset()
func (*GetConnectionRequest) String ¶
func (x *GetConnectionRequest) String() string
type GetConnectionResponse ¶
type GetConnectionResponse struct { SequencerConnections *v30.SequencerConnections `protobuf:"bytes,1,opt,name=sequencer_connections,json=sequencerConnections,proto3" json:"sequencer_connections,omitempty"` // contains filtered or unexported fields }
func (*GetConnectionResponse) Descriptor
deprecated
func (*GetConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetConnectionResponse.ProtoReflect.Descriptor instead.
func (*GetConnectionResponse) GetSequencerConnections ¶
func (x *GetConnectionResponse) GetSequencerConnections() *v30.SequencerConnections
func (*GetConnectionResponse) ProtoMessage ¶
func (*GetConnectionResponse) ProtoMessage()
func (*GetConnectionResponse) ProtoReflect ¶
func (x *GetConnectionResponse) ProtoReflect() protoreflect.Message
func (*GetConnectionResponse) Reset ¶
func (x *GetConnectionResponse) Reset()
func (*GetConnectionResponse) String ¶
func (x *GetConnectionResponse) String() string
type InitializeMediatorRequest ¶
type InitializeMediatorRequest struct { DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"` SequencerConnections *v30.SequencerConnections `protobuf:"bytes,2,opt,name=sequencer_connections,json=sequencerConnections,proto3" json:"sequencer_connections,omitempty"` SequencerConnectionValidation v30.SequencerConnectionValidation `` /* 227-byte string literal not displayed */ // contains filtered or unexported fields }
func (*InitializeMediatorRequest) Descriptor
deprecated
func (*InitializeMediatorRequest) Descriptor() ([]byte, []int)
Deprecated: Use InitializeMediatorRequest.ProtoReflect.Descriptor instead.
func (*InitializeMediatorRequest) GetDomainId ¶
func (x *InitializeMediatorRequest) GetDomainId() string
func (*InitializeMediatorRequest) GetSequencerConnectionValidation ¶
func (x *InitializeMediatorRequest) GetSequencerConnectionValidation() v30.SequencerConnectionValidation
func (*InitializeMediatorRequest) GetSequencerConnections ¶
func (x *InitializeMediatorRequest) GetSequencerConnections() *v30.SequencerConnections
func (*InitializeMediatorRequest) ProtoMessage ¶
func (*InitializeMediatorRequest) ProtoMessage()
func (*InitializeMediatorRequest) ProtoReflect ¶
func (x *InitializeMediatorRequest) ProtoReflect() protoreflect.Message
func (*InitializeMediatorRequest) Reset ¶
func (x *InitializeMediatorRequest) Reset()
func (*InitializeMediatorRequest) String ¶
func (x *InitializeMediatorRequest) String() string
type InitializeMediatorResponse ¶
type InitializeMediatorResponse struct {
// contains filtered or unexported fields
}
func (*InitializeMediatorResponse) Descriptor
deprecated
func (*InitializeMediatorResponse) Descriptor() ([]byte, []int)
Deprecated: Use InitializeMediatorResponse.ProtoReflect.Descriptor instead.
func (*InitializeMediatorResponse) ProtoMessage ¶
func (*InitializeMediatorResponse) ProtoMessage()
func (*InitializeMediatorResponse) ProtoReflect ¶
func (x *InitializeMediatorResponse) ProtoReflect() protoreflect.Message
func (*InitializeMediatorResponse) Reset ¶
func (x *InitializeMediatorResponse) Reset()
func (*InitializeMediatorResponse) String ¶
func (x *InitializeMediatorResponse) String() string
type MediatorAdministrationServiceClient ¶
type MediatorAdministrationServiceClient interface { Prune(ctx context.Context, in *MediatorPruning_PruneRequest, opts ...grpc.CallOption) (*MediatorPruning_PruneResponse, error) SetSchedule(ctx context.Context, in *v30.SetSchedule_Request, opts ...grpc.CallOption) (*v30.SetSchedule_Response, error) SetCron(ctx context.Context, in *v30.SetCron_Request, opts ...grpc.CallOption) (*v30.SetCron_Response, error) SetMaxDuration(ctx context.Context, in *v30.SetMaxDuration_Request, opts ...grpc.CallOption) (*v30.SetMaxDuration_Response, error) SetRetention(ctx context.Context, in *v30.SetRetention_Request, opts ...grpc.CallOption) (*v30.SetRetention_Response, error) ClearSchedule(ctx context.Context, in *v30.ClearSchedule_Request, opts ...grpc.CallOption) (*v30.ClearSchedule_Response, error) GetSchedule(ctx context.Context, in *v30.GetSchedule_Request, opts ...grpc.CallOption) (*v30.GetSchedule_Response, error) LocatePruningTimestamp(ctx context.Context, in *v30.LocatePruningTimestamp_Request, opts ...grpc.CallOption) (*v30.LocatePruningTimestamp_Response, error) }
MediatorAdministrationServiceClient is the client API for MediatorAdministrationService 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 NewMediatorAdministrationServiceClient ¶
func NewMediatorAdministrationServiceClient(cc grpc.ClientConnInterface) MediatorAdministrationServiceClient
type MediatorAdministrationServiceServer ¶
type MediatorAdministrationServiceServer interface { Prune(context.Context, *MediatorPruning_PruneRequest) (*MediatorPruning_PruneResponse, error) SetSchedule(context.Context, *v30.SetSchedule_Request) (*v30.SetSchedule_Response, error) SetCron(context.Context, *v30.SetCron_Request) (*v30.SetCron_Response, error) SetMaxDuration(context.Context, *v30.SetMaxDuration_Request) (*v30.SetMaxDuration_Response, error) SetRetention(context.Context, *v30.SetRetention_Request) (*v30.SetRetention_Response, error) ClearSchedule(context.Context, *v30.ClearSchedule_Request) (*v30.ClearSchedule_Response, error) GetSchedule(context.Context, *v30.GetSchedule_Request) (*v30.GetSchedule_Response, error) LocatePruningTimestamp(context.Context, *v30.LocatePruningTimestamp_Request) (*v30.LocatePruningTimestamp_Response, error) // contains filtered or unexported methods }
MediatorAdministrationServiceServer is the server API for MediatorAdministrationService service. All implementations must embed UnimplementedMediatorAdministrationServiceServer for forward compatibility.
type MediatorInitializationServiceClient ¶
type MediatorInitializationServiceClient interface {
InitializeMediator(ctx context.Context, in *InitializeMediatorRequest, opts ...grpc.CallOption) (*InitializeMediatorResponse, error)
}
MediatorInitializationServiceClient is the client API for MediatorInitializationService 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 NewMediatorInitializationServiceClient ¶
func NewMediatorInitializationServiceClient(cc grpc.ClientConnInterface) MediatorInitializationServiceClient
type MediatorInitializationServiceServer ¶
type MediatorInitializationServiceServer interface { InitializeMediator(context.Context, *InitializeMediatorRequest) (*InitializeMediatorResponse, error) // contains filtered or unexported methods }
MediatorInitializationServiceServer is the server API for MediatorInitializationService service. All implementations must embed UnimplementedMediatorInitializationServiceServer for forward compatibility.
type MediatorPruning ¶
type MediatorPruning struct {
// contains filtered or unexported fields
}
func (*MediatorPruning) Descriptor
deprecated
func (*MediatorPruning) Descriptor() ([]byte, []int)
Deprecated: Use MediatorPruning.ProtoReflect.Descriptor instead.
func (*MediatorPruning) ProtoMessage ¶
func (*MediatorPruning) ProtoMessage()
func (*MediatorPruning) ProtoReflect ¶
func (x *MediatorPruning) ProtoReflect() protoreflect.Message
func (*MediatorPruning) Reset ¶
func (x *MediatorPruning) Reset()
func (*MediatorPruning) String ¶
func (x *MediatorPruning) String() string
type MediatorPruning_PruneRequest ¶
type MediatorPruning_PruneRequest struct { Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*MediatorPruning_PruneRequest) Descriptor
deprecated
func (*MediatorPruning_PruneRequest) Descriptor() ([]byte, []int)
Deprecated: Use MediatorPruning_PruneRequest.ProtoReflect.Descriptor instead.
func (*MediatorPruning_PruneRequest) GetTimestamp ¶
func (x *MediatorPruning_PruneRequest) GetTimestamp() *timestamppb.Timestamp
func (*MediatorPruning_PruneRequest) ProtoMessage ¶
func (*MediatorPruning_PruneRequest) ProtoMessage()
func (*MediatorPruning_PruneRequest) ProtoReflect ¶
func (x *MediatorPruning_PruneRequest) ProtoReflect() protoreflect.Message
func (*MediatorPruning_PruneRequest) Reset ¶
func (x *MediatorPruning_PruneRequest) Reset()
func (*MediatorPruning_PruneRequest) String ¶
func (x *MediatorPruning_PruneRequest) String() string
type MediatorPruning_PruneResponse ¶
type MediatorPruning_PruneResponse struct {
// contains filtered or unexported fields
}
func (*MediatorPruning_PruneResponse) Descriptor
deprecated
func (*MediatorPruning_PruneResponse) Descriptor() ([]byte, []int)
Deprecated: Use MediatorPruning_PruneResponse.ProtoReflect.Descriptor instead.
func (*MediatorPruning_PruneResponse) ProtoMessage ¶
func (*MediatorPruning_PruneResponse) ProtoMessage()
func (*MediatorPruning_PruneResponse) ProtoReflect ¶
func (x *MediatorPruning_PruneResponse) ProtoReflect() protoreflect.Message
func (*MediatorPruning_PruneResponse) Reset ¶
func (x *MediatorPruning_PruneResponse) Reset()
func (*MediatorPruning_PruneResponse) String ¶
func (x *MediatorPruning_PruneResponse) String() string
type SequencerConnectionServiceClient ¶
type SequencerConnectionServiceClient interface { GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error) SetConnection(ctx context.Context, in *SetConnectionRequest, opts ...grpc.CallOption) (*SetConnectionResponse, error) }
SequencerConnectionServiceClient is the client API for SequencerConnectionService 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 NewSequencerConnectionServiceClient ¶
func NewSequencerConnectionServiceClient(cc grpc.ClientConnInterface) SequencerConnectionServiceClient
type SequencerConnectionServiceServer ¶
type SequencerConnectionServiceServer interface { GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error) SetConnection(context.Context, *SetConnectionRequest) (*SetConnectionResponse, error) // contains filtered or unexported methods }
SequencerConnectionServiceServer is the server API for SequencerConnectionService service. All implementations must embed UnimplementedSequencerConnectionServiceServer for forward compatibility.
type SetConnectionRequest ¶
type SetConnectionRequest struct { SequencerConnections *v30.SequencerConnections `protobuf:"bytes,1,opt,name=sequencer_connections,json=sequencerConnections,proto3" json:"sequencer_connections,omitempty"` SequencerConnectionValidation v30.SequencerConnectionValidation `` /* 227-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SetConnectionRequest) Descriptor
deprecated
func (*SetConnectionRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetConnectionRequest.ProtoReflect.Descriptor instead.
func (*SetConnectionRequest) GetSequencerConnectionValidation ¶
func (x *SetConnectionRequest) GetSequencerConnectionValidation() v30.SequencerConnectionValidation
func (*SetConnectionRequest) GetSequencerConnections ¶
func (x *SetConnectionRequest) GetSequencerConnections() *v30.SequencerConnections
func (*SetConnectionRequest) ProtoMessage ¶
func (*SetConnectionRequest) ProtoMessage()
func (*SetConnectionRequest) ProtoReflect ¶
func (x *SetConnectionRequest) ProtoReflect() protoreflect.Message
func (*SetConnectionRequest) Reset ¶
func (x *SetConnectionRequest) Reset()
func (*SetConnectionRequest) String ¶
func (x *SetConnectionRequest) String() string
type SetConnectionResponse ¶
type SetConnectionResponse struct {
// contains filtered or unexported fields
}
func (*SetConnectionResponse) Descriptor
deprecated
func (*SetConnectionResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetConnectionResponse.ProtoReflect.Descriptor instead.
func (*SetConnectionResponse) ProtoMessage ¶
func (*SetConnectionResponse) ProtoMessage()
func (*SetConnectionResponse) ProtoReflect ¶
func (x *SetConnectionResponse) ProtoReflect() protoreflect.Message
func (*SetConnectionResponse) Reset ¶
func (x *SetConnectionResponse) Reset()
func (*SetConnectionResponse) String ¶
func (x *SetConnectionResponse) String() string
type UnimplementedMediatorAdministrationServiceServer ¶
type UnimplementedMediatorAdministrationServiceServer struct{}
UnimplementedMediatorAdministrationServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedMediatorAdministrationServiceServer) ClearSchedule ¶
func (UnimplementedMediatorAdministrationServiceServer) ClearSchedule(context.Context, *v30.ClearSchedule_Request) (*v30.ClearSchedule_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) GetSchedule ¶
func (UnimplementedMediatorAdministrationServiceServer) GetSchedule(context.Context, *v30.GetSchedule_Request) (*v30.GetSchedule_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) LocatePruningTimestamp ¶
func (UnimplementedMediatorAdministrationServiceServer) LocatePruningTimestamp(context.Context, *v30.LocatePruningTimestamp_Request) (*v30.LocatePruningTimestamp_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) SetCron ¶
func (UnimplementedMediatorAdministrationServiceServer) SetCron(context.Context, *v30.SetCron_Request) (*v30.SetCron_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) SetMaxDuration ¶
func (UnimplementedMediatorAdministrationServiceServer) SetMaxDuration(context.Context, *v30.SetMaxDuration_Request) (*v30.SetMaxDuration_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) SetRetention ¶
func (UnimplementedMediatorAdministrationServiceServer) SetRetention(context.Context, *v30.SetRetention_Request) (*v30.SetRetention_Response, error)
func (UnimplementedMediatorAdministrationServiceServer) SetSchedule ¶
func (UnimplementedMediatorAdministrationServiceServer) SetSchedule(context.Context, *v30.SetSchedule_Request) (*v30.SetSchedule_Response, error)
type UnimplementedMediatorInitializationServiceServer ¶
type UnimplementedMediatorInitializationServiceServer struct{}
UnimplementedMediatorInitializationServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedMediatorInitializationServiceServer) InitializeMediator ¶
func (UnimplementedMediatorInitializationServiceServer) InitializeMediator(context.Context, *InitializeMediatorRequest) (*InitializeMediatorResponse, error)
type UnimplementedSequencerConnectionServiceServer ¶
type UnimplementedSequencerConnectionServiceServer struct{}
UnimplementedSequencerConnectionServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedSequencerConnectionServiceServer) GetConnection ¶
func (UnimplementedSequencerConnectionServiceServer) GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
func (UnimplementedSequencerConnectionServiceServer) SetConnection ¶
func (UnimplementedSequencerConnectionServiceServer) SetConnection(context.Context, *SetConnectionRequest) (*SetConnectionResponse, error)
type UnsafeMediatorAdministrationServiceServer ¶
type UnsafeMediatorAdministrationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMediatorAdministrationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MediatorAdministrationServiceServer will result in compilation errors.
type UnsafeMediatorInitializationServiceServer ¶
type UnsafeMediatorInitializationServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMediatorInitializationServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MediatorInitializationServiceServer will result in compilation errors.
type UnsafeSequencerConnectionServiceServer ¶
type UnsafeSequencerConnectionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSequencerConnectionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SequencerConnectionServiceServer will result in compilation errors.