v0

package
v7.12.0 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DomainInitializationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.DomainInitializationService",
	HandlerType: (*DomainInitializationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _DomainInitializationService_Init_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/domain_initialization_service.proto",
}

DomainInitializationService_ServiceDesc is the grpc.ServiceDesc for DomainInitializationService 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 DomainService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.DomainService",
	HandlerType: (*DomainServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListServiceAgreementAcceptances",
			Handler:    _DomainService_ListServiceAgreementAcceptances_Handler,
		},
		{
			MethodName: "GetDomainParameters",
			Handler:    _DomainService_GetDomainParameters_Handler,
		},
		{
			MethodName: "GetDomainParametersVersioned",
			Handler:    _DomainService_GetDomainParametersVersioned_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/domain_service.proto",
}

DomainService_ServiceDesc is the grpc.ServiceDesc for DomainService 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 EnterpriseMediatorAdministrationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.EnterpriseMediatorAdministrationService",
	HandlerType: (*EnterpriseMediatorAdministrationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Prune",
			Handler:    _EnterpriseMediatorAdministrationService_Prune_Handler,
		},
		{
			MethodName: "SetSchedule",
			Handler:    _EnterpriseMediatorAdministrationService_SetSchedule_Handler,
		},
		{
			MethodName: "SetCron",
			Handler:    _EnterpriseMediatorAdministrationService_SetCron_Handler,
		},
		{
			MethodName: "SetMaxDuration",
			Handler:    _EnterpriseMediatorAdministrationService_SetMaxDuration_Handler,
		},
		{
			MethodName: "SetRetention",
			Handler:    _EnterpriseMediatorAdministrationService_SetRetention_Handler,
		},
		{
			MethodName: "ClearSchedule",
			Handler:    _EnterpriseMediatorAdministrationService_ClearSchedule_Handler,
		},
		{
			MethodName: "GetSchedule",
			Handler:    _EnterpriseMediatorAdministrationService_GetSchedule_Handler,
		},
		{
			MethodName: "LocatePruningTimestamp",
			Handler:    _EnterpriseMediatorAdministrationService_LocatePruningTimestamp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/enterprise_mediator_administration_service.proto",
}

EnterpriseMediatorAdministrationService_ServiceDesc is the grpc.ServiceDesc for EnterpriseMediatorAdministrationService 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 EnterpriseSequencerAdministrationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.EnterpriseSequencerAdministrationService",
	HandlerType: (*EnterpriseSequencerAdministrationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Prune",
			Handler:    _EnterpriseSequencerAdministrationService_Prune_Handler,
		},
		{
			MethodName: "Snapshot",
			Handler:    _EnterpriseSequencerAdministrationService_Snapshot_Handler,
		},
		{
			MethodName: "DisableMember",
			Handler:    _EnterpriseSequencerAdministrationService_DisableMember_Handler,
		},
		{
			MethodName: "AuthorizeLedgerIdentity",
			Handler:    _EnterpriseSequencerAdministrationService_AuthorizeLedgerIdentity_Handler,
		},
		{
			MethodName: "SetSchedule",
			Handler:    _EnterpriseSequencerAdministrationService_SetSchedule_Handler,
		},
		{
			MethodName: "SetCron",
			Handler:    _EnterpriseSequencerAdministrationService_SetCron_Handler,
		},
		{
			MethodName: "SetMaxDuration",
			Handler:    _EnterpriseSequencerAdministrationService_SetMaxDuration_Handler,
		},
		{
			MethodName: "SetRetention",
			Handler:    _EnterpriseSequencerAdministrationService_SetRetention_Handler,
		},
		{
			MethodName: "ClearSchedule",
			Handler:    _EnterpriseSequencerAdministrationService_ClearSchedule_Handler,
		},
		{
			MethodName: "GetSchedule",
			Handler:    _EnterpriseSequencerAdministrationService_GetSchedule_Handler,
		},
		{
			MethodName: "LocatePruningTimestamp",
			Handler:    _EnterpriseSequencerAdministrationService_LocatePruningTimestamp_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/enterprise_sequencer_administration_service.proto",
}

EnterpriseSequencerAdministrationService_ServiceDesc is the grpc.ServiceDesc for EnterpriseSequencerAdministrationService 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 EnterpriseSequencerConnectionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.EnterpriseSequencerConnectionService",
	HandlerType: (*EnterpriseSequencerConnectionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetConnection",
			Handler:    _EnterpriseSequencerConnectionService_GetConnection_Handler,
		},
		{
			MethodName: "SetConnection",
			Handler:    _EnterpriseSequencerConnectionService_SetConnection_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/enterprise_sequencer_connection_service.proto",
}

EnterpriseSequencerConnectionService_ServiceDesc is the grpc.ServiceDesc for EnterpriseSequencerConnectionService 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 File_com_digitalasset_canton_domain_admin_v0_domain_initialization_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_domain_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_enterprise_mediator_administration_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_enterprise_sequencer_administration_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_enterprise_sequencer_connection_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_mediator_initialization_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_sequencer_administration_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_sequencer_initialization_snapshot_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_admin_v0_sequencer_version_service_proto protoreflect.FileDescriptor
View Source 
var MediatorInitializationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.MediatorInitializationService",
	HandlerType: (*MediatorInitializationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Initialize",
			Handler:    _MediatorInitializationService_Initialize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/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 SequencerAdministrationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.SequencerAdministrationService",
	HandlerType: (*SequencerAdministrationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PruningStatus",
			Handler:    _SequencerAdministrationService_PruningStatus_Handler,
		},
		{
			MethodName: "TrafficControlState",
			Handler:    _SequencerAdministrationService_TrafficControlState_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/sequencer_administration_service.proto",
}

SequencerAdministrationService_ServiceDesc is the grpc.ServiceDesc for SequencerAdministrationService 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 SequencerVersionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.admin.v0.SequencerVersionService",
	HandlerType: (*SequencerVersionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Handshake",
			Handler:    _SequencerVersionService_Handshake_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/admin/v0/sequencer_version_service.proto",
}

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

Functions

func RegisterDomainInitializationServiceServer 

func RegisterDomainInitializationServiceServer(s grpc.ServiceRegistrar, srv DomainInitializationServiceServer)

func RegisterDomainServiceServer 

func RegisterDomainServiceServer(s grpc.ServiceRegistrar, srv DomainServiceServer)

func RegisterEnterpriseMediatorAdministrationServiceServer 

func RegisterEnterpriseMediatorAdministrationServiceServer(s grpc.ServiceRegistrar, srv EnterpriseMediatorAdministrationServiceServer)

func RegisterEnterpriseSequencerAdministrationServiceServer 

func RegisterEnterpriseSequencerAdministrationServiceServer(s grpc.ServiceRegistrar, srv EnterpriseSequencerAdministrationServiceServer)

func RegisterEnterpriseSequencerConnectionServiceServer 

func RegisterEnterpriseSequencerConnectionServiceServer(s grpc.ServiceRegistrar, srv EnterpriseSequencerConnectionServiceServer)

func RegisterMediatorInitializationServiceServer 

func RegisterMediatorInitializationServiceServer(s grpc.ServiceRegistrar, srv MediatorInitializationServiceServer)

func RegisterSequencerAdministrationServiceServer 

func RegisterSequencerAdministrationServiceServer(s grpc.ServiceRegistrar, srv SequencerAdministrationServiceServer)

func RegisterSequencerVersionServiceServer 

func RegisterSequencerVersionServiceServer(s grpc.ServiceRegistrar, srv SequencerVersionServiceServer)

Types

type DisableMemberRequest 

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

func (*DisableMemberRequest) Descriptor deprecated 

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

Deprecated: Use DisableMemberRequest.ProtoReflect.Descriptor instead.

func (*DisableMemberRequest) GetMember 

func (x *DisableMemberRequest) GetMember() string

func (*DisableMemberRequest) ProtoMessage 

func (*DisableMemberRequest) ProtoMessage()

func (*DisableMemberRequest) ProtoReflect 

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

func (*DisableMemberRequest) Reset 

func (x *DisableMemberRequest) Reset()

func (*DisableMemberRequest) String 

func (x *DisableMemberRequest) String() string

type DomainInitRequest 

type DomainInitRequest struct {
	Config *DomainNodeSequencerConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainInitRequest) Descriptor deprecated 

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

Deprecated: Use DomainInitRequest.ProtoReflect.Descriptor instead.

func (*DomainInitRequest) GetConfig 

func (x *DomainInitRequest) GetConfig() *DomainNodeSequencerConfig

func (*DomainInitRequest) ProtoMessage 

func (*DomainInitRequest) ProtoMessage()

func (*DomainInitRequest) ProtoReflect 

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

func (*DomainInitRequest) Reset 

func (x *DomainInitRequest) Reset()

func (*DomainInitRequest) String 

func (x *DomainInitRequest) String() string

type DomainInitializationServiceClient 

type DomainInitializationServiceClient interface {
	// triggers the initialization of a domain node that has been setup with an external sequencer
	// this should be called after the external sequencer's (and optionally other initial sequencers') keys have been
	// authorized by the IDM and posteriorly sequenced by one of the sequencers
	Init(ctx context.Context, in *DomainInitRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DomainInitializationServiceClient is the client API for DomainInitializationService 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 NewDomainInitializationServiceClient 

func NewDomainInitializationServiceClient(cc grpc.ClientConnInterface) DomainInitializationServiceClient

type DomainInitializationServiceServer 

type DomainInitializationServiceServer interface {
	// triggers the initialization of a domain node that has been setup with an external sequencer
	// this should be called after the external sequencer's (and optionally other initial sequencers') keys have been
	// authorized by the IDM and posteriorly sequenced by one of the sequencers
	Init(context.Context, *DomainInitRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DomainInitializationServiceServer is the server API for DomainInitializationService service. All implementations must embed UnimplementedDomainInitializationServiceServer for forward compatibility

type DomainNodeSequencerConfig 

type DomainNodeSequencerConfig struct {

	// connection information to sequencer
	SequencerConnection *v0.SequencerConnection `protobuf:"bytes,1,opt,name=sequencerConnection,proto3" json:"sequencerConnection,omitempty"`
	// contains filtered or unexported fields
}

func (*DomainNodeSequencerConfig) Descriptor deprecated 

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

Deprecated: Use DomainNodeSequencerConfig.ProtoReflect.Descriptor instead.

func (*DomainNodeSequencerConfig) GetSequencerConnection 

func (x *DomainNodeSequencerConfig) GetSequencerConnection() *v0.SequencerConnection

func (*DomainNodeSequencerConfig) ProtoMessage 

func (*DomainNodeSequencerConfig) ProtoMessage()

func (*DomainNodeSequencerConfig) ProtoReflect 

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

func (*DomainNodeSequencerConfig) Reset 

func (x *DomainNodeSequencerConfig) Reset()

func (*DomainNodeSequencerConfig) String 

func (x *DomainNodeSequencerConfig) String() string

type DomainServiceClient 

type DomainServiceClient interface {
	ListServiceAgreementAcceptances(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ServiceAgreementAcceptances, error)
	GetDomainParameters(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*v0.StaticDomainParameters, error)
	GetDomainParametersVersioned(ctx context.Context, in *GetDomainParameters_Request, opts ...grpc.CallOption) (*GetDomainParameters_Response, error)
}

DomainServiceClient is the client API for DomainService 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 NewDomainServiceClient 

func NewDomainServiceClient(cc grpc.ClientConnInterface) DomainServiceClient

type DomainServiceServer 

type DomainServiceServer interface {
	ListServiceAgreementAcceptances(context.Context, *emptypb.Empty) (*ServiceAgreementAcceptances, error)
	GetDomainParameters(context.Context, *emptypb.Empty) (*v0.StaticDomainParameters, error)
	GetDomainParametersVersioned(context.Context, *GetDomainParameters_Request) (*GetDomainParameters_Response, error)
	// contains filtered or unexported methods
}

DomainServiceServer is the server API for DomainService service. All implementations must embed UnimplementedDomainServiceServer for forward compatibility

type EnterpriseMediatorAdministrationServiceClient 

type EnterpriseMediatorAdministrationServiceClient interface {
	// Remove unnecessary data from the Mediator
	Prune(ctx context.Context, in *MediatorPruningRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Enable automatic pruning using the specified schedule parameters
	// The following errors may occur on the SetSchedule or Update commands:
	// - “INVALID_ARGUMENT“: if a parameter is missing or an invalid cron expression
	//   or duration.
	// - “FAILED_PRECONDITION“: if automatic background pruning has not been enabled
	//   or if invoked on a participant running the Community Edition.
	SetSchedule(ctx context.Context, in *v0.SetSchedule_Request, opts ...grpc.CallOption) (*v0.SetSchedule_Response, error)
	// Modify individual pruning schedule parameters.
	// - “INVALID_ARGUMENT“: if the payload is malformed or no schedule is configured
	SetCron(ctx context.Context, in *v0.SetCron_Request, opts ...grpc.CallOption) (*v0.SetCron_Response, error)
	SetMaxDuration(ctx context.Context, in *v0.SetMaxDuration_Request, opts ...grpc.CallOption) (*v0.SetMaxDuration_Response, error)
	SetRetention(ctx context.Context, in *v0.SetRetention_Request, opts ...grpc.CallOption) (*v0.SetRetention_Response, error)
	// Disable automatic pruning and remove the persisted schedule configuration.
	ClearSchedule(ctx context.Context, in *v0.ClearSchedule_Request, opts ...grpc.CallOption) (*v0.ClearSchedule_Response, error)
	// Retrieve the automatic pruning configuration.
	GetSchedule(ctx context.Context, in *v0.GetSchedule_Request, opts ...grpc.CallOption) (*v0.GetSchedule_Response, error)
	// Retrieve pruning timestamp at or near the "beginning" of events.
	LocatePruningTimestamp(ctx context.Context, in *v0.LocatePruningTimestamp_Request, opts ...grpc.CallOption) (*v0.LocatePruningTimestamp_Response, error)
}

EnterpriseMediatorAdministrationServiceClient is the client API for EnterpriseMediatorAdministrationService 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 NewEnterpriseMediatorAdministrationServiceClient 

func NewEnterpriseMediatorAdministrationServiceClient(cc grpc.ClientConnInterface) EnterpriseMediatorAdministrationServiceClient

type EnterpriseMediatorAdministrationServiceServer 

type EnterpriseMediatorAdministrationServiceServer interface {
	// Remove unnecessary data from the Mediator
	Prune(context.Context, *MediatorPruningRequest) (*emptypb.Empty, error)
	// Enable automatic pruning using the specified schedule parameters
	// The following errors may occur on the SetSchedule or Update commands:
	// - “INVALID_ARGUMENT“: if a parameter is missing or an invalid cron expression
	//   or duration.
	// - “FAILED_PRECONDITION“: if automatic background pruning has not been enabled
	//   or if invoked on a participant running the Community Edition.
	SetSchedule(context.Context, *v0.SetSchedule_Request) (*v0.SetSchedule_Response, error)
	// Modify individual pruning schedule parameters.
	// - “INVALID_ARGUMENT“: if the payload is malformed or no schedule is configured
	SetCron(context.Context, *v0.SetCron_Request) (*v0.SetCron_Response, error)
	SetMaxDuration(context.Context, *v0.SetMaxDuration_Request) (*v0.SetMaxDuration_Response, error)
	SetRetention(context.Context, *v0.SetRetention_Request) (*v0.SetRetention_Response, error)
	// Disable automatic pruning and remove the persisted schedule configuration.
	ClearSchedule(context.Context, *v0.ClearSchedule_Request) (*v0.ClearSchedule_Response, error)
	// Retrieve the automatic pruning configuration.
	GetSchedule(context.Context, *v0.GetSchedule_Request) (*v0.GetSchedule_Response, error)
	// Retrieve pruning timestamp at or near the "beginning" of events.
	LocatePruningTimestamp(context.Context, *v0.LocatePruningTimestamp_Request) (*v0.LocatePruningTimestamp_Response, error)
	// contains filtered or unexported methods
}

EnterpriseMediatorAdministrationServiceServer is the server API for EnterpriseMediatorAdministrationService service. All implementations must embed UnimplementedEnterpriseMediatorAdministrationServiceServer for forward compatibility

type EnterpriseSequencerAdministrationServiceClient 

type EnterpriseSequencerAdministrationServiceClient interface {
	// Remove data from the Sequencer
	Prune(ctx context.Context, in *Pruning_Request, opts ...grpc.CallOption) (*Pruning_Response, error)
	// fetch a snapshot of the sequencer state based on the given timestamp
	Snapshot(ctx context.Context, in *Snapshot_Request, opts ...grpc.CallOption) (*Snapshot_Response, error)
	// Disable members at the sequencer. Will prevent existing and new instances from connecting, and permit removing their data.
	DisableMember(ctx context.Context, in *DisableMemberRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AuthorizeLedgerIdentity(ctx context.Context, in *LedgerIdentity_AuthorizeRequest, opts ...grpc.CallOption) (*LedgerIdentity_AuthorizeResponse, error)
	// Enable automatic pruning using the specified schedule parameters
	// The following errors may occur on the SetSchedule or Update commands:
	// - “INVALID_ARGUMENT“: if a parameter is missing or an invalid cron expression
	//   or duration.
	// - “FAILED_PRECONDITION“: if automatic background pruning has not been enabled
	//   or if invoked on a participant running the Community Edition.
	SetSchedule(ctx context.Context, in *v0.SetSchedule_Request, opts ...grpc.CallOption) (*v0.SetSchedule_Response, error)
	// Modify individual pruning schedule parameters.
	// - “INVALID_ARGUMENT“: if the payload is malformed or no schedule is configured
	SetCron(ctx context.Context, in *v0.SetCron_Request, opts ...grpc.CallOption) (*v0.SetCron_Response, error)
	SetMaxDuration(ctx context.Context, in *v0.SetMaxDuration_Request, opts ...grpc.CallOption) (*v0.SetMaxDuration_Response, error)
	SetRetention(ctx context.Context, in *v0.SetRetention_Request, opts ...grpc.CallOption) (*v0.SetRetention_Response, error)
	// Disable automatic pruning and remove the persisted schedule configuration.
	ClearSchedule(ctx context.Context, in *v0.ClearSchedule_Request, opts ...grpc.CallOption) (*v0.ClearSchedule_Response, error)
	// Retrieve the automatic pruning configuration.
	GetSchedule(ctx context.Context, in *v0.GetSchedule_Request, opts ...grpc.CallOption) (*v0.GetSchedule_Response, error)
	// Retrieve pruning timestamp at or near the "beginning" of events.
	LocatePruningTimestamp(ctx context.Context, in *v0.LocatePruningTimestamp_Request, opts ...grpc.CallOption) (*v0.LocatePruningTimestamp_Response, error)
}

EnterpriseSequencerAdministrationServiceClient is the client API for EnterpriseSequencerAdministrationService 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 NewEnterpriseSequencerAdministrationServiceClient 

func NewEnterpriseSequencerAdministrationServiceClient(cc grpc.ClientConnInterface) EnterpriseSequencerAdministrationServiceClient

type EnterpriseSequencerAdministrationServiceServer 

type EnterpriseSequencerAdministrationServiceServer interface {
	// Remove data from the Sequencer
	Prune(context.Context, *Pruning_Request) (*Pruning_Response, error)
	// fetch a snapshot of the sequencer state based on the given timestamp
	Snapshot(context.Context, *Snapshot_Request) (*Snapshot_Response, error)
	// Disable members at the sequencer. Will prevent existing and new instances from connecting, and permit removing their data.
	DisableMember(context.Context, *DisableMemberRequest) (*emptypb.Empty, error)
	AuthorizeLedgerIdentity(context.Context, *LedgerIdentity_AuthorizeRequest) (*LedgerIdentity_AuthorizeResponse, error)
	// Enable automatic pruning using the specified schedule parameters
	// The following errors may occur on the SetSchedule or Update commands:
	// - “INVALID_ARGUMENT“: if a parameter is missing or an invalid cron expression
	//   or duration.
	// - “FAILED_PRECONDITION“: if automatic background pruning has not been enabled
	//   or if invoked on a participant running the Community Edition.
	SetSchedule(context.Context, *v0.SetSchedule_Request) (*v0.SetSchedule_Response, error)
	// Modify individual pruning schedule parameters.
	// - “INVALID_ARGUMENT“: if the payload is malformed or no schedule is configured
	SetCron(context.Context, *v0.SetCron_Request) (*v0.SetCron_Response, error)
	SetMaxDuration(context.Context, *v0.SetMaxDuration_Request) (*v0.SetMaxDuration_Response, error)
	SetRetention(context.Context, *v0.SetRetention_Request) (*v0.SetRetention_Response, error)
	// Disable automatic pruning and remove the persisted schedule configuration.
	ClearSchedule(context.Context, *v0.ClearSchedule_Request) (*v0.ClearSchedule_Response, error)
	// Retrieve the automatic pruning configuration.
	GetSchedule(context.Context, *v0.GetSchedule_Request) (*v0.GetSchedule_Response, error)
	// Retrieve pruning timestamp at or near the "beginning" of events.
	LocatePruningTimestamp(context.Context, *v0.LocatePruningTimestamp_Request) (*v0.LocatePruningTimestamp_Response, error)
	// contains filtered or unexported methods
}

EnterpriseSequencerAdministrationServiceServer is the server API for EnterpriseSequencerAdministrationService service. All implementations must embed UnimplementedEnterpriseSequencerAdministrationServiceServer for forward compatibility

type EnterpriseSequencerConnectionServiceClient 

type EnterpriseSequencerConnectionServiceClient interface {
	GetConnection(ctx context.Context, in *GetConnectionRequest, opts ...grpc.CallOption) (*GetConnectionResponse, error)
	SetConnection(ctx context.Context, in *SetConnectionRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EnterpriseSequencerConnectionServiceClient is the client API for EnterpriseSequencerConnectionService 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 NewEnterpriseSequencerConnectionServiceClient 

func NewEnterpriseSequencerConnectionServiceClient(cc grpc.ClientConnInterface) EnterpriseSequencerConnectionServiceClient

type EnterpriseSequencerConnectionServiceServer 

type EnterpriseSequencerConnectionServiceServer interface {
	GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)
	SetConnection(context.Context, *SetConnectionRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

EnterpriseSequencerConnectionServiceServer is the server API for EnterpriseSequencerConnectionService service. All implementations must embed UnimplementedEnterpriseSequencerConnectionServiceServer for forward compatibility

type EthereumAccount 

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

func (*EthereumAccount) Descriptor deprecated 

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

Deprecated: Use EthereumAccount.ProtoReflect.Descriptor instead.

func (*EthereumAccount) GetAddress 

func (x *EthereumAccount) GetAddress() string

func (*EthereumAccount) ProtoMessage 

func (*EthereumAccount) ProtoMessage()

func (*EthereumAccount) ProtoReflect 

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

func (*EthereumAccount) Reset 

func (x *EthereumAccount) Reset()

func (*EthereumAccount) String 

func (x *EthereumAccount) String() string

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 []*v0.SequencerConnection `protobuf:"bytes,1,rep,name=sequencer_connections,json=sequencerConnections,proto3" json:"sequencer_connections,omitempty"`
	// This field determines the minimum level of agreement, or consensus, required among the sequencers before a message
	// is considered reliable and accepted by the system.
	// The value set here should not be zero. However, to maintain backward compatibility with older clients, a zero value
	// is interpreted as equivalent to the size of sequencer_connections.
	SequencerTrustThreshold uint32 `protobuf:"varint,2,opt,name=sequencerTrustThreshold,proto3" json:"sequencerTrustThreshold,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() []*v0.SequencerConnection

func (*GetConnectionResponse) GetSequencerTrustThreshold 

func (x *GetConnectionResponse) GetSequencerTrustThreshold() uint32

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 GetDomainParameters 

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

func (*GetDomainParameters) Descriptor deprecated 

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

Deprecated: Use GetDomainParameters.ProtoReflect.Descriptor instead.

func (*GetDomainParameters) ProtoMessage 

func (*GetDomainParameters) ProtoMessage()

func (*GetDomainParameters) ProtoReflect 

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

func (*GetDomainParameters) Reset 

func (x *GetDomainParameters) Reset()

func (*GetDomainParameters) String 

func (x *GetDomainParameters) String() string

type GetDomainParameters_Request 

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

func (*GetDomainParameters_Request) Descriptor deprecated 

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

Deprecated: Use GetDomainParameters_Request.ProtoReflect.Descriptor instead.

func (*GetDomainParameters_Request) ProtoMessage 

func (*GetDomainParameters_Request) ProtoMessage()

func (*GetDomainParameters_Request) ProtoReflect 

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

func (*GetDomainParameters_Request) Reset 

func (x *GetDomainParameters_Request) Reset()

func (*GetDomainParameters_Request) String 

func (x *GetDomainParameters_Request) String() string

type GetDomainParameters_Response 

type GetDomainParameters_Response struct {

	// Types that are assignable to Parameters:
	//	*GetDomainParameters_Response_ParametersV0
	//	*GetDomainParameters_Response_ParametersV1
	Parameters isGetDomainParameters_Response_Parameters `protobuf_oneof:"parameters"`
	// contains filtered or unexported fields
}

func (*GetDomainParameters_Response) Descriptor deprecated 

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

Deprecated: Use GetDomainParameters_Response.ProtoReflect.Descriptor instead.

func (*GetDomainParameters_Response) GetParameters 

func (m *GetDomainParameters_Response) GetParameters() isGetDomainParameters_Response_Parameters

func (*GetDomainParameters_Response) GetParametersV0 

func (x *GetDomainParameters_Response) GetParametersV0() *v01.StaticDomainParameters

func (*GetDomainParameters_Response) GetParametersV1 

func (x *GetDomainParameters_Response) GetParametersV1() *v1.StaticDomainParameters

func (*GetDomainParameters_Response) ProtoMessage 

func (*GetDomainParameters_Response) ProtoMessage()

func (*GetDomainParameters_Response) ProtoReflect 

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

func (*GetDomainParameters_Response) Reset 

func (x *GetDomainParameters_Response) Reset()

func (*GetDomainParameters_Response) String 

func (x *GetDomainParameters_Response) String() string

type GetDomainParameters_Response_ParametersV0 

type GetDomainParameters_Response_ParametersV0 struct {
	ParametersV0 *v01.StaticDomainParameters `protobuf:"bytes,1,opt,name=parameters_v0,json=parametersV0,proto3,oneof"`
}

type GetDomainParameters_Response_ParametersV1 

type GetDomainParameters_Response_ParametersV1 struct {
	ParametersV1 *v1.StaticDomainParameters `protobuf:"bytes,2,opt,name=parameters_v1,json=parametersV1,proto3,oneof"`
}

type ImplementationSpecificInfo 

type ImplementationSpecificInfo struct {
	ImplementationName string `protobuf:"bytes,1,opt,name=implementation_name,json=implementationName,proto3" json:"implementation_name,omitempty"`
	Info               []byte `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

additional sequencer implementation specific piece of data

func (*ImplementationSpecificInfo) Descriptor deprecated 

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

Deprecated: Use ImplementationSpecificInfo.ProtoReflect.Descriptor instead.

func (*ImplementationSpecificInfo) GetImplementationName 

func (x *ImplementationSpecificInfo) GetImplementationName() string

func (*ImplementationSpecificInfo) GetInfo 

func (x *ImplementationSpecificInfo) GetInfo() []byte

func (*ImplementationSpecificInfo) ProtoMessage 

func (*ImplementationSpecificInfo) ProtoMessage()

func (*ImplementationSpecificInfo) ProtoReflect 

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

func (*ImplementationSpecificInfo) Reset 

func (x *ImplementationSpecificInfo) Reset()

func (*ImplementationSpecificInfo) String 

func (x *ImplementationSpecificInfo) String() string

type InitializeMediatorRequest 

type InitializeMediatorRequest struct {

	// the domain identifier
	DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	// the mediator identifier
	MediatorId string `protobuf:"bytes,2,opt,name=mediator_id,json=mediatorId,proto3" json:"mediator_id,omitempty"`
	// topology state required for startup
	CurrentIdentityState *v0.TopologyTransactions `protobuf:"bytes,3,opt,name=current_identity_state,json=currentIdentityState,proto3" json:"current_identity_state,omitempty"`
	// parameters for the domain (includes the protocol version which needs to match the protocol version the domain
	// manager is running)
	DomainParameters *v0.StaticDomainParameters `protobuf:"bytes,4,opt,name=domain_parameters,json=domainParameters,proto3" json:"domain_parameters,omitempty"`
	// how should the member connect to the domain sequencer
	SequencerConnection *v01.SequencerConnection `protobuf:"bytes,5,opt,name=sequencer_connection,json=sequencerConnection,proto3" json:"sequencer_connection,omitempty"`
	// Optional fingerprint of the signing key the mediator should use. This key should already exist and have been
	// authorized during domain bootstrap
	SigningKeyFingerprint *wrapperspb.StringValue `` /* 126-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) GetCurrentIdentityState 

func (x *InitializeMediatorRequest) GetCurrentIdentityState() *v0.TopologyTransactions

func (*InitializeMediatorRequest) GetDomainId 

func (x *InitializeMediatorRequest) GetDomainId() string

func (*InitializeMediatorRequest) GetDomainParameters 

func (x *InitializeMediatorRequest) GetDomainParameters() *v0.StaticDomainParameters

func (*InitializeMediatorRequest) GetMediatorId 

func (x *InitializeMediatorRequest) GetMediatorId() string

func (*InitializeMediatorRequest) GetSequencerConnection 

func (x *InitializeMediatorRequest) GetSequencerConnection() *v01.SequencerConnection

func (*InitializeMediatorRequest) GetSigningKeyFingerprint 

func (x *InitializeMediatorRequest) GetSigningKeyFingerprint() *wrapperspb.StringValue

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 {

	// Types that are assignable to Value:
	//	*InitializeMediatorResponse_Success_
	//	*InitializeMediatorResponse_Failure_
	Value isInitializeMediatorResponse_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*InitializeMediatorResponse) Descriptor deprecated 

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

Deprecated: Use InitializeMediatorResponse.ProtoReflect.Descriptor instead.

func (*InitializeMediatorResponse) GetFailure 

func (x *InitializeMediatorResponse) GetFailure() *InitializeMediatorResponse_Failure

func (*InitializeMediatorResponse) GetSuccess 

func (x *InitializeMediatorResponse) GetSuccess() *InitializeMediatorResponse_Success

func (*InitializeMediatorResponse) GetValue 

func (m *InitializeMediatorResponse) GetValue() isInitializeMediatorResponse_Value

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 InitializeMediatorResponse_Failure 

type InitializeMediatorResponse_Failure struct {

	// Reason that can be logged
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeMediatorResponse_Failure) Descriptor deprecated 

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

Deprecated: Use InitializeMediatorResponse_Failure.ProtoReflect.Descriptor instead.

func (*InitializeMediatorResponse_Failure) GetReason 

func (x *InitializeMediatorResponse_Failure) GetReason() string

func (*InitializeMediatorResponse_Failure) ProtoMessage 

func (*InitializeMediatorResponse_Failure) ProtoMessage()

func (*InitializeMediatorResponse_Failure) ProtoReflect 

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

func (*InitializeMediatorResponse_Failure) Reset 

func (x *InitializeMediatorResponse_Failure) Reset()

func (*InitializeMediatorResponse_Failure) String 

func (x *InitializeMediatorResponse_Failure) String() string

type InitializeMediatorResponse_Failure_ 

type InitializeMediatorResponse_Failure_ struct {
	Failure *InitializeMediatorResponse_Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type InitializeMediatorResponse_Success 

type InitializeMediatorResponse_Success struct {

	// Current signing key
	MediatorKey *v02.SigningPublicKey `protobuf:"bytes,1,opt,name=mediator_key,json=mediatorKey,proto3" json:"mediator_key,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeMediatorResponse_Success) Descriptor deprecated 

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

Deprecated: Use InitializeMediatorResponse_Success.ProtoReflect.Descriptor instead.

func (*InitializeMediatorResponse_Success) GetMediatorKey 

func (x *InitializeMediatorResponse_Success) GetMediatorKey() *v02.SigningPublicKey

func (*InitializeMediatorResponse_Success) ProtoMessage 

func (*InitializeMediatorResponse_Success) ProtoMessage()

func (*InitializeMediatorResponse_Success) ProtoReflect 

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

func (*InitializeMediatorResponse_Success) Reset 

func (x *InitializeMediatorResponse_Success) Reset()

func (*InitializeMediatorResponse_Success) String 

func (x *InitializeMediatorResponse_Success) String() string

type InitializeMediatorResponse_Success_ 

type InitializeMediatorResponse_Success_ struct {
	Success *InitializeMediatorResponse_Success `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type LedgerIdentity 

type LedgerIdentity struct {

	// Types that are assignable to Identifier:
	//	*LedgerIdentity_EthereumAccount
	Identifier isLedgerIdentity_Identifier `protobuf_oneof:"identifier"`
	// contains filtered or unexported fields
}

func (*LedgerIdentity) Descriptor deprecated 

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

Deprecated: Use LedgerIdentity.ProtoReflect.Descriptor instead.

func (*LedgerIdentity) GetEthereumAccount 

func (x *LedgerIdentity) GetEthereumAccount() *EthereumAccount

func (*LedgerIdentity) GetIdentifier 

func (m *LedgerIdentity) GetIdentifier() isLedgerIdentity_Identifier

func (*LedgerIdentity) ProtoMessage 

func (*LedgerIdentity) ProtoMessage()

func (*LedgerIdentity) ProtoReflect 

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

func (*LedgerIdentity) Reset 

func (x *LedgerIdentity) Reset()

func (*LedgerIdentity) String 

func (x *LedgerIdentity) String() string

type LedgerIdentity_AuthorizeRequest 

type LedgerIdentity_AuthorizeRequest struct {
	Identify *LedgerIdentity `protobuf:"bytes,1,opt,name=identify,proto3" json:"identify,omitempty"`
	// contains filtered or unexported fields
}

func (*LedgerIdentity_AuthorizeRequest) Descriptor deprecated 

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

Deprecated: Use LedgerIdentity_AuthorizeRequest.ProtoReflect.Descriptor instead.

func (*LedgerIdentity_AuthorizeRequest) GetIdentify 

func (x *LedgerIdentity_AuthorizeRequest) GetIdentify() *LedgerIdentity

func (*LedgerIdentity_AuthorizeRequest) ProtoMessage 

func (*LedgerIdentity_AuthorizeRequest) ProtoMessage()

func (*LedgerIdentity_AuthorizeRequest) ProtoReflect 

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

func (*LedgerIdentity_AuthorizeRequest) Reset 

func (x *LedgerIdentity_AuthorizeRequest) Reset()

func (*LedgerIdentity_AuthorizeRequest) String 

func (x *LedgerIdentity_AuthorizeRequest) String() string

type LedgerIdentity_AuthorizeResponse 

type LedgerIdentity_AuthorizeResponse struct {

	// Types that are assignable to Value:
	//	*LedgerIdentity_AuthorizeResponse_Success
	//	*LedgerIdentity_AuthorizeResponse_Failure
	Value isLedgerIdentity_AuthorizeResponse_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*LedgerIdentity_AuthorizeResponse) Descriptor deprecated 

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

Deprecated: Use LedgerIdentity_AuthorizeResponse.ProtoReflect.Descriptor instead.

func (*LedgerIdentity_AuthorizeResponse) GetFailure 

func (x *LedgerIdentity_AuthorizeResponse) GetFailure() *LedgerIdentity_Failure

func (*LedgerIdentity_AuthorizeResponse) GetSuccess 

func (x *LedgerIdentity_AuthorizeResponse) GetSuccess() *LedgerIdentity_Success

func (*LedgerIdentity_AuthorizeResponse) GetValue 

func (m *LedgerIdentity_AuthorizeResponse) GetValue() isLedgerIdentity_AuthorizeResponse_Value

func (*LedgerIdentity_AuthorizeResponse) ProtoMessage 

func (*LedgerIdentity_AuthorizeResponse) ProtoMessage()

func (*LedgerIdentity_AuthorizeResponse) ProtoReflect 

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

func (*LedgerIdentity_AuthorizeResponse) Reset 

func (x *LedgerIdentity_AuthorizeResponse) Reset()

func (*LedgerIdentity_AuthorizeResponse) String 

func (x *LedgerIdentity_AuthorizeResponse) String() string

type LedgerIdentity_AuthorizeResponse_Failure 

type LedgerIdentity_AuthorizeResponse_Failure struct {
	Failure *LedgerIdentity_Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type LedgerIdentity_AuthorizeResponse_Success 

type LedgerIdentity_AuthorizeResponse_Success struct {
	Success *LedgerIdentity_Success `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type LedgerIdentity_EthereumAccount 

type LedgerIdentity_EthereumAccount struct {
	EthereumAccount *EthereumAccount `protobuf:"bytes,1,opt,name=ethereum_account,json=ethereumAccount,proto3,oneof"`
}

type LedgerIdentity_Failure 

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

func (*LedgerIdentity_Failure) Descriptor deprecated 

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

Deprecated: Use LedgerIdentity_Failure.ProtoReflect.Descriptor instead.

func (*LedgerIdentity_Failure) GetReason 

func (x *LedgerIdentity_Failure) GetReason() string

func (*LedgerIdentity_Failure) ProtoMessage 

func (*LedgerIdentity_Failure) ProtoMessage()

func (*LedgerIdentity_Failure) ProtoReflect 

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

func (*LedgerIdentity_Failure) Reset 

func (x *LedgerIdentity_Failure) Reset()

func (*LedgerIdentity_Failure) String 

func (x *LedgerIdentity_Failure) String() string

type LedgerIdentity_Success 

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

func (*LedgerIdentity_Success) Descriptor deprecated 

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

Deprecated: Use LedgerIdentity_Success.ProtoReflect.Descriptor instead.

func (*LedgerIdentity_Success) ProtoMessage 

func (*LedgerIdentity_Success) ProtoMessage()

func (*LedgerIdentity_Success) ProtoReflect 

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

func (*LedgerIdentity_Success) Reset 

func (x *LedgerIdentity_Success) Reset()

func (*LedgerIdentity_Success) String 

func (x *LedgerIdentity_Success) String() string

type MediatorInitializationServiceClient 

type MediatorInitializationServiceClient interface {
	// Initialize a Mediator service
	// If the Mediator is uninitialized it should initialize itself with the provided configuration
	// If the Mediator is already initialized then verify the request is for the domain we're running against,
	// if correct then just return the current key otherwise fail.
	Initialize(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 {
	// Initialize a Mediator service
	// If the Mediator is uninitialized it should initialize itself with the provided configuration
	// If the Mediator is already initialized then verify the request is for the domain we're running against,
	// if correct then just return the current key otherwise fail.
	Initialize(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 MediatorPruningRequest 

type MediatorPruningRequest struct {

	// timestamp to prune for
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*MediatorPruningRequest) Descriptor deprecated 

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

Deprecated: Use MediatorPruningRequest.ProtoReflect.Descriptor instead.

func (*MediatorPruningRequest) GetTimestamp 

func (x *MediatorPruningRequest) GetTimestamp() *timestamppb.Timestamp

func (*MediatorPruningRequest) ProtoMessage 

func (*MediatorPruningRequest) ProtoMessage()

func (*MediatorPruningRequest) ProtoReflect 

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

func (*MediatorPruningRequest) Reset 

func (x *MediatorPruningRequest) Reset()

func (*MediatorPruningRequest) String 

func (x *MediatorPruningRequest) String() string

type Pruning 

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

func (*Pruning) Descriptor deprecated 

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

Deprecated: Use Pruning.ProtoReflect.Descriptor instead.

func (*Pruning) ProtoMessage 

func (*Pruning) ProtoMessage()

func (*Pruning) ProtoReflect 

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

func (*Pruning) Reset 

func (x *Pruning) Reset()

func (*Pruning) String 

func (x *Pruning) String() string

type Pruning_Request 

type Pruning_Request struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Pruning_Request) Descriptor deprecated 

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

Deprecated: Use Pruning_Request.ProtoReflect.Descriptor instead.

func (*Pruning_Request) GetTimestamp 

func (x *Pruning_Request) GetTimestamp() *timestamppb.Timestamp

func (*Pruning_Request) ProtoMessage 

func (*Pruning_Request) ProtoMessage()

func (*Pruning_Request) ProtoReflect 

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

func (*Pruning_Request) Reset 

func (x *Pruning_Request) Reset()

func (*Pruning_Request) String 

func (x *Pruning_Request) String() string

type Pruning_Response 

type Pruning_Response struct {

	// description of what was removed
	Details string `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*Pruning_Response) Descriptor deprecated 

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

Deprecated: Use Pruning_Response.ProtoReflect.Descriptor instead.

func (*Pruning_Response) GetDetails 

func (x *Pruning_Response) GetDetails() string

func (*Pruning_Response) ProtoMessage 

func (*Pruning_Response) ProtoMessage()

func (*Pruning_Response) ProtoReflect 

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

func (*Pruning_Response) Reset 

func (x *Pruning_Response) Reset()

func (*Pruning_Response) String 

func (x *Pruning_Response) String() string

type SequencerAdministrationServiceClient 

type SequencerAdministrationServiceClient interface {
	// fetch the current status of the sequencer
	PruningStatus(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*SequencerPruningStatus, error)
	TrafficControlState(ctx context.Context, in *TrafficControlStateRequest, opts ...grpc.CallOption) (*TrafficControlStateResponse, error)
}

SequencerAdministrationServiceClient is the client API for SequencerAdministrationService 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 NewSequencerAdministrationServiceClient 

func NewSequencerAdministrationServiceClient(cc grpc.ClientConnInterface) SequencerAdministrationServiceClient

type SequencerAdministrationServiceServer 

type SequencerAdministrationServiceServer interface {
	// fetch the current status of the sequencer
	PruningStatus(context.Context, *emptypb.Empty) (*SequencerPruningStatus, error)
	TrafficControlState(context.Context, *TrafficControlStateRequest) (*TrafficControlStateResponse, error)
	// contains filtered or unexported methods
}

SequencerAdministrationServiceServer is the server API for SequencerAdministrationService service. All implementations must embed UnimplementedSequencerAdministrationServiceServer for forward compatibility

type SequencerMemberStatus 

type SequencerMemberStatus struct {
	Member           string                 `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	RegisteredAt     *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"`
	LastAcknowledged *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_acknowledged,json=lastAcknowledged,proto3" json:"last_acknowledged,omitempty"`
	Enabled          bool                   `protobuf:"varint,4,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerMemberStatus) Descriptor deprecated 

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

Deprecated: Use SequencerMemberStatus.ProtoReflect.Descriptor instead.

func (*SequencerMemberStatus) GetEnabled 

func (x *SequencerMemberStatus) GetEnabled() bool

func (*SequencerMemberStatus) GetLastAcknowledged 

func (x *SequencerMemberStatus) GetLastAcknowledged() *timestamppb.Timestamp

func (*SequencerMemberStatus) GetMember 

func (x *SequencerMemberStatus) GetMember() string

func (*SequencerMemberStatus) GetRegisteredAt 

func (x *SequencerMemberStatus) GetRegisteredAt() *timestamppb.Timestamp

func (*SequencerMemberStatus) ProtoMessage 

func (*SequencerMemberStatus) ProtoMessage()

func (*SequencerMemberStatus) ProtoReflect 

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

func (*SequencerMemberStatus) Reset 

func (x *SequencerMemberStatus) Reset()

func (*SequencerMemberStatus) String 

func (x *SequencerMemberStatus) String() string

type SequencerPruningStatus 

type SequencerPruningStatus struct {

	// current time according to the sequencer
	Now *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=now,proto3" json:"now,omitempty"`
	// the earliest event we are currently storing
	EarliestEventTimestamp *timestamppb.Timestamp `` /* 129-byte string literal not displayed */
	// details of each member registered on the sequencer
	Members []*SequencerMemberStatus `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerPruningStatus) Descriptor deprecated 

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

Deprecated: Use SequencerPruningStatus.ProtoReflect.Descriptor instead.

func (*SequencerPruningStatus) GetEarliestEventTimestamp 

func (x *SequencerPruningStatus) GetEarliestEventTimestamp() *timestamppb.Timestamp

func (*SequencerPruningStatus) GetMembers 

func (x *SequencerPruningStatus) GetMembers() []*SequencerMemberStatus

func (*SequencerPruningStatus) GetNow 

func (x *SequencerPruningStatus) GetNow() *timestamppb.Timestamp

func (*SequencerPruningStatus) ProtoMessage 

func (*SequencerPruningStatus) ProtoMessage()

func (*SequencerPruningStatus) ProtoReflect 

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

func (*SequencerPruningStatus) Reset 

func (x *SequencerPruningStatus) Reset()

func (*SequencerPruningStatus) String 

func (x *SequencerPruningStatus) String() string

type SequencerSnapshot 

type SequencerSnapshot struct {
	LatestTimestamp    *timestamppb.Timestamp      `protobuf:"bytes,1,opt,name=latest_timestamp,json=latestTimestamp,proto3" json:"latest_timestamp,omitempty"`
	HeadMemberCounters map[string]int64            `` /* 206-byte string literal not displayed */
	Status             *SequencerPruningStatus     `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	Additional         *ImplementationSpecificInfo `protobuf:"bytes,4,opt,name=additional,proto3" json:"additional,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerSnapshot) Descriptor deprecated 

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

Deprecated: Use SequencerSnapshot.ProtoReflect.Descriptor instead.

func (*SequencerSnapshot) GetAdditional 

func (x *SequencerSnapshot) GetAdditional() *ImplementationSpecificInfo

func (*SequencerSnapshot) GetHeadMemberCounters 

func (x *SequencerSnapshot) GetHeadMemberCounters() map[string]int64

func (*SequencerSnapshot) GetLatestTimestamp 

func (x *SequencerSnapshot) GetLatestTimestamp() *timestamppb.Timestamp

func (*SequencerSnapshot) GetStatus 

func (x *SequencerSnapshot) GetStatus() *SequencerPruningStatus

func (*SequencerSnapshot) ProtoMessage 

func (*SequencerSnapshot) ProtoMessage()

func (*SequencerSnapshot) ProtoReflect 

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

func (*SequencerSnapshot) Reset 

func (x *SequencerSnapshot) Reset()

func (*SequencerSnapshot) String 

func (x *SequencerSnapshot) String() string

type SequencerVersionServiceClient 

type SequencerVersionServiceClient interface {
	// Perform a handshake with the initialization service to ensure that the client and server are using compatible versions
	Handshake(ctx context.Context, in *v0.Handshake_Request, opts ...grpc.CallOption) (*v0.Handshake_Response, error)
}

SequencerVersionServiceClient is the client API for SequencerVersionService 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 NewSequencerVersionServiceClient 

func NewSequencerVersionServiceClient(cc grpc.ClientConnInterface) SequencerVersionServiceClient

type SequencerVersionServiceServer 

type SequencerVersionServiceServer interface {
	// Perform a handshake with the initialization service to ensure that the client and server are using compatible versions
	Handshake(context.Context, *v0.Handshake_Request) (*v0.Handshake_Response, error)
	// contains filtered or unexported methods
}

SequencerVersionServiceServer is the server API for SequencerVersionService service. All implementations must embed UnimplementedSequencerVersionServiceServer for forward compatibility

type ServiceAgreementAcceptance 

type ServiceAgreementAcceptance struct {
	AgreementId   string `protobuf:"bytes,1,opt,name=agreement_id,json=agreementId,proto3" json:"agreement_id,omitempty"`
	ParticipantId string `protobuf:"bytes,2,opt,name=participant_id,json=participantId,proto3" json:"participant_id,omitempty"`
	// The signature by the participant when accepting the agreement as part of the auth token challenge response protocol
	Signature *v0.Signature `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	// When the agreement was first accepted
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceAgreementAcceptance) Descriptor deprecated 

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

Deprecated: Use ServiceAgreementAcceptance.ProtoReflect.Descriptor instead.

func (*ServiceAgreementAcceptance) GetAgreementId 

func (x *ServiceAgreementAcceptance) GetAgreementId() string

func (*ServiceAgreementAcceptance) GetParticipantId 

func (x *ServiceAgreementAcceptance) GetParticipantId() string

func (*ServiceAgreementAcceptance) GetSignature 

func (x *ServiceAgreementAcceptance) GetSignature() *v0.Signature

func (*ServiceAgreementAcceptance) GetTimestamp 

func (x *ServiceAgreementAcceptance) GetTimestamp() *timestamppb.Timestamp

func (*ServiceAgreementAcceptance) ProtoMessage 

func (*ServiceAgreementAcceptance) ProtoMessage()

func (*ServiceAgreementAcceptance) ProtoReflect 

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

func (*ServiceAgreementAcceptance) Reset 

func (x *ServiceAgreementAcceptance) Reset()

func (*ServiceAgreementAcceptance) String 

func (x *ServiceAgreementAcceptance) String() string

type ServiceAgreementAcceptances 

type ServiceAgreementAcceptances struct {
	Acceptances []*ServiceAgreementAcceptance `protobuf:"bytes,1,rep,name=acceptances,proto3" json:"acceptances,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceAgreementAcceptances) Descriptor deprecated 

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

Deprecated: Use ServiceAgreementAcceptances.ProtoReflect.Descriptor instead.

func (*ServiceAgreementAcceptances) GetAcceptances 

func (x *ServiceAgreementAcceptances) GetAcceptances() []*ServiceAgreementAcceptance

func (*ServiceAgreementAcceptances) ProtoMessage 

func (*ServiceAgreementAcceptances) ProtoMessage()

func (*ServiceAgreementAcceptances) ProtoReflect 

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

func (*ServiceAgreementAcceptances) Reset 

func (x *ServiceAgreementAcceptances) Reset()

func (*ServiceAgreementAcceptances) String 

func (x *ServiceAgreementAcceptances) String() string

type SetConnectionRequest 

type SetConnectionRequest struct {
	SequencerConnections []*v0.SequencerConnection `protobuf:"bytes,1,rep,name=sequencer_connections,json=sequencerConnections,proto3" json:"sequencer_connections,omitempty"`
	// This field determines the minimum level of agreement, or consensus, required among the sequencers before a message
	// is considered reliable and accepted by the system.
	// The value set here should not be zero. However, to maintain backward compatibility with older clients, a zero value
	// is interpreted as equivalent to the size of sequencer_connections.
	SequencerTrustThreshold uint32 `protobuf:"varint,2,opt,name=sequencerTrustThreshold,proto3" json:"sequencerTrustThreshold,omitempty"`
	// contains filtered or unexported fields
}

func (*SetConnectionRequest) Descriptor deprecated 

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

Deprecated: Use SetConnectionRequest.ProtoReflect.Descriptor instead.

func (*SetConnectionRequest) GetSequencerConnections 

func (x *SetConnectionRequest) GetSequencerConnections() []*v0.SequencerConnection

func (*SetConnectionRequest) GetSequencerTrustThreshold 

func (x *SetConnectionRequest) GetSequencerTrustThreshold() uint32

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 Snapshot 

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

func (*Snapshot) Descriptor deprecated 

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) ProtoMessage 

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect 

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

func (*Snapshot) Reset 

func (x *Snapshot) Reset()

func (*Snapshot) String 

func (x *Snapshot) String() string

type Snapshot_Failure 

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

func (*Snapshot_Failure) Descriptor deprecated 

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

Deprecated: Use Snapshot_Failure.ProtoReflect.Descriptor instead.

func (*Snapshot_Failure) GetReason 

func (x *Snapshot_Failure) GetReason() string

func (*Snapshot_Failure) ProtoMessage 

func (*Snapshot_Failure) ProtoMessage()

func (*Snapshot_Failure) ProtoReflect 

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

func (*Snapshot_Failure) Reset 

func (x *Snapshot_Failure) Reset()

func (*Snapshot_Failure) String 

func (x *Snapshot_Failure) String() string

type Snapshot_Request 

type Snapshot_Request struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot_Request) Descriptor deprecated 

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

Deprecated: Use Snapshot_Request.ProtoReflect.Descriptor instead.

func (*Snapshot_Request) GetTimestamp 

func (x *Snapshot_Request) GetTimestamp() *timestamppb.Timestamp

func (*Snapshot_Request) ProtoMessage 

func (*Snapshot_Request) ProtoMessage()

func (*Snapshot_Request) ProtoReflect 

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

func (*Snapshot_Request) Reset 

func (x *Snapshot_Request) Reset()

func (*Snapshot_Request) String 

func (x *Snapshot_Request) String() string

type Snapshot_Response 

type Snapshot_Response struct {

	// Types that are assignable to Value:
	//	*Snapshot_Response_Success
	//	*Snapshot_Response_Failure
	//	*Snapshot_Response_VersionedSuccess
	Value isSnapshot_Response_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Snapshot_Response) Descriptor deprecated 

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

Deprecated: Use Snapshot_Response.ProtoReflect.Descriptor instead.

func (*Snapshot_Response) GetFailure 

func (x *Snapshot_Response) GetFailure() *Snapshot_Failure

func (*Snapshot_Response) GetSuccess 

func (x *Snapshot_Response) GetSuccess() *Snapshot_Success

func (*Snapshot_Response) GetValue 

func (m *Snapshot_Response) GetValue() isSnapshot_Response_Value

func (*Snapshot_Response) GetVersionedSuccess 

func (x *Snapshot_Response) GetVersionedSuccess() *Snapshot_VersionedSuccess

func (*Snapshot_Response) ProtoMessage 

func (*Snapshot_Response) ProtoMessage()

func (*Snapshot_Response) ProtoReflect 

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

func (*Snapshot_Response) Reset 

func (x *Snapshot_Response) Reset()

func (*Snapshot_Response) String 

func (x *Snapshot_Response) String() string

type Snapshot_Response_Failure 

type Snapshot_Response_Failure struct {
	Failure *Snapshot_Failure `protobuf:"bytes,2,opt,name=failure,proto3,oneof"`
}

type Snapshot_Response_Success 

type Snapshot_Response_Success struct {
	// Used for sequencers running protocol versions up to v5
	Success *Snapshot_Success `protobuf:"bytes,1,opt,name=success,proto3,oneof"`
}

type Snapshot_Response_VersionedSuccess 

type Snapshot_Response_VersionedSuccess struct {
	// TODO(#12373) Adapt when releasing BFT
	// Used for sequencers running protocol version dev or higher.
	VersionedSuccess *Snapshot_VersionedSuccess `protobuf:"bytes,3,opt,name=versionedSuccess,proto3,oneof"`
}

type Snapshot_Success 

type Snapshot_Success struct {
	State *SequencerSnapshot `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot_Success) Descriptor deprecated 

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

Deprecated: Use Snapshot_Success.ProtoReflect.Descriptor instead.

func (*Snapshot_Success) GetState 

func (x *Snapshot_Success) GetState() *SequencerSnapshot

func (*Snapshot_Success) ProtoMessage 

func (*Snapshot_Success) ProtoMessage()

func (*Snapshot_Success) ProtoReflect 

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

func (*Snapshot_Success) Reset 

func (x *Snapshot_Success) Reset()

func (*Snapshot_Success) String 

func (x *Snapshot_Success) String() string

type Snapshot_VersionedSuccess 

type Snapshot_VersionedSuccess struct {

	// Contains a versioned SequencerSnapshot of version v1 or higher
	Snapshot []byte `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot_VersionedSuccess) Descriptor deprecated 

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

Deprecated: Use Snapshot_VersionedSuccess.ProtoReflect.Descriptor instead.

func (*Snapshot_VersionedSuccess) GetSnapshot 

func (x *Snapshot_VersionedSuccess) GetSnapshot() []byte

func (*Snapshot_VersionedSuccess) ProtoMessage 

func (*Snapshot_VersionedSuccess) ProtoMessage()

func (*Snapshot_VersionedSuccess) ProtoReflect 

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

func (*Snapshot_VersionedSuccess) Reset 

func (x *Snapshot_VersionedSuccess) Reset()

func (*Snapshot_VersionedSuccess) String 

func (x *Snapshot_VersionedSuccess) String() string

type TrafficControlStateRequest 

type TrafficControlStateRequest struct {
	Members []string `protobuf:"bytes,1,rep,name=members,proto3" json:"members,omitempty"` // Members for which to retrieve the traffic state
	// contains filtered or unexported fields
}

func (*TrafficControlStateRequest) Descriptor deprecated 

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

Deprecated: Use TrafficControlStateRequest.ProtoReflect.Descriptor instead.

func (*TrafficControlStateRequest) GetMembers 

func (x *TrafficControlStateRequest) GetMembers() []string

func (*TrafficControlStateRequest) ProtoMessage 

func (*TrafficControlStateRequest) ProtoMessage()

func (*TrafficControlStateRequest) ProtoReflect 

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

func (*TrafficControlStateRequest) Reset 

func (x *TrafficControlStateRequest) Reset()

func (*TrafficControlStateRequest) String 

func (x *TrafficControlStateRequest) String() string

type TrafficControlStateResponse 

type TrafficControlStateResponse struct {
	TrafficStates []*v0.MemberTrafficStatus `protobuf:"bytes,1,rep,name=traffic_states,json=trafficStates,proto3" json:"traffic_states,omitempty"`
	// contains filtered or unexported fields
}

func (*TrafficControlStateResponse) Descriptor deprecated 

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

Deprecated: Use TrafficControlStateResponse.ProtoReflect.Descriptor instead.

func (*TrafficControlStateResponse) GetTrafficStates 

func (x *TrafficControlStateResponse) GetTrafficStates() []*v0.MemberTrafficStatus

func (*TrafficControlStateResponse) ProtoMessage 

func (*TrafficControlStateResponse) ProtoMessage()

func (*TrafficControlStateResponse) ProtoReflect 

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

func (*TrafficControlStateResponse) Reset 

func (x *TrafficControlStateResponse) Reset()

func (*TrafficControlStateResponse) String 

func (x *TrafficControlStateResponse) String() string

type UnimplementedDomainInitializationServiceServer 

type UnimplementedDomainInitializationServiceServer struct {
}

UnimplementedDomainInitializationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainInitializationServiceServer) Init 

func (UnimplementedDomainInitializationServiceServer) Init(context.Context, *DomainInitRequest) (*emptypb.Empty, error)

type UnimplementedDomainServiceServer 

type UnimplementedDomainServiceServer struct {
}

UnimplementedDomainServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainServiceServer) GetDomainParameters 

func (UnimplementedDomainServiceServer) GetDomainParameters(context.Context, *emptypb.Empty) (*v0.StaticDomainParameters, error)

func (UnimplementedDomainServiceServer) GetDomainParametersVersioned 

func (UnimplementedDomainServiceServer) GetDomainParametersVersioned(context.Context, *GetDomainParameters_Request) (*GetDomainParameters_Response, error)

func (UnimplementedDomainServiceServer) ListServiceAgreementAcceptances 

func (UnimplementedDomainServiceServer) ListServiceAgreementAcceptances(context.Context, *emptypb.Empty) (*ServiceAgreementAcceptances, error)

type UnimplementedEnterpriseMediatorAdministrationServiceServer 

type UnimplementedEnterpriseMediatorAdministrationServiceServer struct {
}

UnimplementedEnterpriseMediatorAdministrationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) ClearSchedule 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) ClearSchedule(context.Context, *v0.ClearSchedule_Request) (*v0.ClearSchedule_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) GetSchedule 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) GetSchedule(context.Context, *v0.GetSchedule_Request) (*v0.GetSchedule_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) LocatePruningTimestamp 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) LocatePruningTimestamp(context.Context, *v0.LocatePruningTimestamp_Request) (*v0.LocatePruningTimestamp_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) Prune 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) Prune(context.Context, *MediatorPruningRequest) (*emptypb.Empty, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetCron 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetCron(context.Context, *v0.SetCron_Request) (*v0.SetCron_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetMaxDuration 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetMaxDuration(context.Context, *v0.SetMaxDuration_Request) (*v0.SetMaxDuration_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetRetention 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetRetention(context.Context, *v0.SetRetention_Request) (*v0.SetRetention_Response, error)

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetSchedule 

func (UnimplementedEnterpriseMediatorAdministrationServiceServer) SetSchedule(context.Context, *v0.SetSchedule_Request) (*v0.SetSchedule_Response, error)

type UnimplementedEnterpriseSequencerAdministrationServiceServer 

type UnimplementedEnterpriseSequencerAdministrationServiceServer struct {
}

UnimplementedEnterpriseSequencerAdministrationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) AuthorizeLedgerIdentity 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) AuthorizeLedgerIdentity(context.Context, *LedgerIdentity_AuthorizeRequest) (*LedgerIdentity_AuthorizeResponse, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) ClearSchedule 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) ClearSchedule(context.Context, *v0.ClearSchedule_Request) (*v0.ClearSchedule_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) DisableMember 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) DisableMember(context.Context, *DisableMemberRequest) (*emptypb.Empty, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) GetSchedule 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) GetSchedule(context.Context, *v0.GetSchedule_Request) (*v0.GetSchedule_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) LocatePruningTimestamp 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) LocatePruningTimestamp(context.Context, *v0.LocatePruningTimestamp_Request) (*v0.LocatePruningTimestamp_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) Prune 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) Prune(context.Context, *Pruning_Request) (*Pruning_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetCron 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetCron(context.Context, *v0.SetCron_Request) (*v0.SetCron_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetMaxDuration 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetMaxDuration(context.Context, *v0.SetMaxDuration_Request) (*v0.SetMaxDuration_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetRetention 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetRetention(context.Context, *v0.SetRetention_Request) (*v0.SetRetention_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetSchedule 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) SetSchedule(context.Context, *v0.SetSchedule_Request) (*v0.SetSchedule_Response, error)

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) Snapshot 

func (UnimplementedEnterpriseSequencerAdministrationServiceServer) Snapshot(context.Context, *Snapshot_Request) (*Snapshot_Response, error)

type UnimplementedEnterpriseSequencerConnectionServiceServer 

type UnimplementedEnterpriseSequencerConnectionServiceServer struct {
}

UnimplementedEnterpriseSequencerConnectionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedEnterpriseSequencerConnectionServiceServer) GetConnection 

func (UnimplementedEnterpriseSequencerConnectionServiceServer) GetConnection(context.Context, *GetConnectionRequest) (*GetConnectionResponse, error)

func (UnimplementedEnterpriseSequencerConnectionServiceServer) SetConnection 

func (UnimplementedEnterpriseSequencerConnectionServiceServer) SetConnection(context.Context, *SetConnectionRequest) (*emptypb.Empty, error)

type UnimplementedMediatorInitializationServiceServer 

type UnimplementedMediatorInitializationServiceServer struct {
}

UnimplementedMediatorInitializationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedMediatorInitializationServiceServer) Initialize 

func (UnimplementedMediatorInitializationServiceServer) Initialize(context.Context, *InitializeMediatorRequest) (*InitializeMediatorResponse, error)

type UnimplementedSequencerAdministrationServiceServer 

type UnimplementedSequencerAdministrationServiceServer struct {
}

UnimplementedSequencerAdministrationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerAdministrationServiceServer) PruningStatus 

func (UnimplementedSequencerAdministrationServiceServer) PruningStatus(context.Context, *emptypb.Empty) (*SequencerPruningStatus, error)

func (UnimplementedSequencerAdministrationServiceServer) TrafficControlState 

func (UnimplementedSequencerAdministrationServiceServer) TrafficControlState(context.Context, *TrafficControlStateRequest) (*TrafficControlStateResponse, error)

type UnimplementedSequencerVersionServiceServer 

type UnimplementedSequencerVersionServiceServer struct {
}

UnimplementedSequencerVersionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerVersionServiceServer) Handshake 

func (UnimplementedSequencerVersionServiceServer) Handshake(context.Context, *v0.Handshake_Request) (*v0.Handshake_Response, error)

type UnsafeDomainInitializationServiceServer 

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

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

type UnsafeDomainServiceServer 

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

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

type UnsafeEnterpriseMediatorAdministrationServiceServer 

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

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

type UnsafeEnterpriseSequencerAdministrationServiceServer 

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

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

type UnsafeEnterpriseSequencerConnectionServiceServer 

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

UnsafeEnterpriseSequencerConnectionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EnterpriseSequencerConnectionServiceServer 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 UnsafeSequencerAdministrationServiceServer 

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

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

type UnsafeSequencerVersionServiceServer 

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

UnsafeSequencerVersionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SequencerVersionServiceServer 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.