v30

package
v8.0.0 Latest Latest
Warning

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

Go to latest
Published: Mar 10, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	SequencerConnectionService_GetConnection_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.SequencerConnectionService/GetConnection"
	SequencerConnectionService_SetConnection_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.SequencerConnectionService/SetConnection"
)
View Source
const (
	MediatorInitializationService_InitializeMediator_FullMethodName = "/com.digitalasset.canton.mediator.admin.v30.MediatorInitializationService/InitializeMediator"
)

Variables

View Source
var File_com_digitalasset_canton_mediator_admin_v30_mediator_administration_service_proto protoreflect.FileDescriptor
View Source
var File_com_digitalasset_canton_mediator_admin_v30_mediator_initialization_service_proto protoreflect.FileDescriptor
View Source
var File_com_digitalasset_canton_mediator_admin_v30_sequencer_connection_service_proto protoreflect.FileDescriptor
View Source
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)

View Source
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)

View Source
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 (*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 (*InitializeMediatorResponse) Reset

func (x *InitializeMediatorResponse) Reset()

func (*InitializeMediatorResponse) String

func (x *InitializeMediatorResponse) String() string

type MediatorAdministrationServiceClient

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.

type MediatorAdministrationServiceServer

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.

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 (*MediatorPruning_PruneRequest) ProtoMessage

func (*MediatorPruning_PruneRequest) ProtoMessage()

func (*MediatorPruning_PruneRequest) ProtoReflect

func (*MediatorPruning_PruneRequest) Reset

func (x *MediatorPruning_PruneRequest) Reset()

func (*MediatorPruning_PruneRequest) 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 (*MediatorPruning_PruneResponse) Reset

func (x *MediatorPruning_PruneResponse) Reset()

func (*MediatorPruning_PruneResponse) 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.

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) GetSchedule

func (UnimplementedMediatorAdministrationServiceServer) SetCron

func (UnimplementedMediatorAdministrationServiceServer) SetMaxDuration

func (UnimplementedMediatorAdministrationServiceServer) SetRetention

func (UnimplementedMediatorAdministrationServiceServer) SetSchedule

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

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) SetConnection

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL