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: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SequencerApiType_name = map[int32]string{
		0: "Grpc",
	}
	SequencerApiType_value = map[string]int32{
		"Grpc": 0,
	}
)

Enum value maps for SequencerApiType.

View Source 
var DomainService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.api.v0.DomainService",
	HandlerType: (*DomainServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetServiceAgreement",
			Handler:    _DomainService_GetServiceAgreement_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/api/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 DomainTimeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.api.v0.DomainTimeService",
	HandlerType: (*DomainTimeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchTime",
			Handler:    _DomainTimeService_FetchTime_Handler,
		},
		{
			MethodName: "AwaitTime",
			Handler:    _DomainTimeService_AwaitTime_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/api/v0/domain_time_service.proto",
}

DomainTimeService_ServiceDesc is the grpc.ServiceDesc for DomainTimeService 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_api_v0_domain_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_domain_time_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_sequencer_authentication_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_sequencer_connect_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_sequencer_connection_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_sequencer_service_proto protoreflect.FileDescriptor
View Source 
var File_com_digitalasset_canton_domain_api_v0_service_agreement_proto protoreflect.FileDescriptor
View Source 
var SequencerAuthenticationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.api.v0.SequencerAuthenticationService",
	HandlerType: (*SequencerAuthenticationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Challenge",
			Handler:    _SequencerAuthenticationService_Challenge_Handler,
		},
		{
			MethodName: "Authenticate",
			Handler:    _SequencerAuthenticationService_Authenticate_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/api/v0/sequencer_authentication_service.proto",
}

SequencerAuthenticationService_ServiceDesc is the grpc.ServiceDesc for SequencerAuthenticationService 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 SequencerConnectService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.api.v0.SequencerConnectService",
	HandlerType: (*SequencerConnectServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Handshake",
			Handler:    _SequencerConnectService_Handshake_Handler,
		},
		{
			MethodName: "GetDomainId",
			Handler:    _SequencerConnectService_GetDomainId_Handler,
		},
		{
			MethodName: "GetDomainParameters",
			Handler:    _SequencerConnectService_GetDomainParameters_Handler,
		},
		{
			MethodName: "VerifyActive",
			Handler:    _SequencerConnectService_VerifyActive_Handler,
		},
		{
			MethodName: "GetServiceAgreement",
			Handler:    _SequencerConnectService_GetServiceAgreement_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "com/digitalasset/canton/domain/api/v0/sequencer_connect_service.proto",
}

SequencerConnectService_ServiceDesc is the grpc.ServiceDesc for SequencerConnectService 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 SequencerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "com.digitalasset.canton.domain.api.v0.SequencerService",
	HandlerType: (*SequencerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SendAsync",
			Handler:    _SequencerService_SendAsync_Handler,
		},
		{
			MethodName: "SendAsyncSigned",
			Handler:    _SequencerService_SendAsyncSigned_Handler,
		},
		{
			MethodName: "SendAsyncUnauthenticated",
			Handler:    _SequencerService_SendAsyncUnauthenticated_Handler,
		},
		{
			MethodName: "SendAsyncVersioned",
			Handler:    _SequencerService_SendAsyncVersioned_Handler,
		},
		{
			MethodName: "SendAsyncUnauthenticatedVersioned",
			Handler:    _SequencerService_SendAsyncUnauthenticatedVersioned_Handler,
		},
		{
			MethodName: "Acknowledge",
			Handler:    _SequencerService_Acknowledge_Handler,
		},
		{
			MethodName: "AcknowledgeSigned",
			Handler:    _SequencerService_AcknowledgeSigned_Handler,
		},
		{
			MethodName: "DownloadTopologyStateForInit",
			Handler:    _SequencerService_DownloadTopologyStateForInit_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _SequencerService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeVersioned",
			Handler:       _SequencerService_SubscribeVersioned_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeUnauthenticated",
			Handler:       _SequencerService_SubscribeUnauthenticated_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeUnauthenticatedVersioned",
			Handler:       _SequencerService_SubscribeUnauthenticatedVersioned_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "com/digitalasset/canton/domain/api/v0/sequencer_service.proto",
}

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

Functions

func RegisterDomainServiceServer deprecated 

func RegisterDomainServiceServer(s grpc.ServiceRegistrar, srv DomainServiceServer)

Deprecated: Do not use.

func RegisterDomainTimeServiceServer 

func RegisterDomainTimeServiceServer(s grpc.ServiceRegistrar, srv DomainTimeServiceServer)

func RegisterSequencerAuthenticationServiceServer 

func RegisterSequencerAuthenticationServiceServer(s grpc.ServiceRegistrar, srv SequencerAuthenticationServiceServer)

func RegisterSequencerConnectServiceServer 

func RegisterSequencerConnectServiceServer(s grpc.ServiceRegistrar, srv SequencerConnectServiceServer)

func RegisterSequencerServiceServer 

func RegisterSequencerServiceServer(s grpc.ServiceRegistrar, srv SequencerServiceServer)

Types

type AcknowledgeRequest 

type AcknowledgeRequest struct {

	// Who is the acknowledgement being sent on behalf of
	Member string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// The timestamp in sequencer time that they are acknowledging and will not re-read earlier events.
	// It is expected that the caller has a received an event with this timestamp but this is not validated.
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AcknowledgeRequest) Descriptor deprecated 

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

Deprecated: Use AcknowledgeRequest.ProtoReflect.Descriptor instead.

func (*AcknowledgeRequest) GetMember 

func (x *AcknowledgeRequest) GetMember() string

func (*AcknowledgeRequest) GetTimestamp 

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

func (*AcknowledgeRequest) ProtoMessage 

func (*AcknowledgeRequest) ProtoMessage()

func (*AcknowledgeRequest) ProtoReflect 

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

func (*AcknowledgeRequest) Reset 

func (x *AcknowledgeRequest) Reset()

func (*AcknowledgeRequest) String 

func (x *AcknowledgeRequest) String() string

type Authentication 

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

func (*Authentication) Descriptor deprecated 

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

Deprecated: Use Authentication.ProtoReflect.Descriptor instead.

func (*Authentication) ProtoMessage 

func (*Authentication) ProtoMessage()

func (*Authentication) ProtoReflect 

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

func (*Authentication) Reset 

func (x *Authentication) Reset()

func (*Authentication) String 

func (x *Authentication) String() string

type Authentication_Failure 

type Authentication_Failure struct {
	Code   uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Authentication_Failure) Descriptor deprecated 

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

Deprecated: Use Authentication_Failure.ProtoReflect.Descriptor instead.

func (*Authentication_Failure) GetCode 

func (x *Authentication_Failure) GetCode() uint32

func (*Authentication_Failure) GetReason 

func (x *Authentication_Failure) GetReason() string

func (*Authentication_Failure) ProtoMessage 

func (*Authentication_Failure) ProtoMessage()

func (*Authentication_Failure) ProtoReflect 

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

func (*Authentication_Failure) Reset 

func (x *Authentication_Failure) Reset()

func (*Authentication_Failure) String 

func (x *Authentication_Failure) String() string

type Authentication_Request 

type Authentication_Request struct {

	// member sending request
	Member string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// signature of the handshake nonce concatenated with the identity of the domain (fingerprint)
	Signature *v0.Signature `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	// nonce value that was signed is sent back to identify the challenge
	Nonce []byte `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

func (*Authentication_Request) Descriptor deprecated 

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

Deprecated: Use Authentication_Request.ProtoReflect.Descriptor instead.

func (*Authentication_Request) GetMember 

func (x *Authentication_Request) GetMember() string

func (*Authentication_Request) GetNonce 

func (x *Authentication_Request) GetNonce() []byte

func (*Authentication_Request) GetSignature 

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

func (*Authentication_Request) ProtoMessage 

func (*Authentication_Request) ProtoMessage()

func (*Authentication_Request) ProtoReflect 

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

func (*Authentication_Request) Reset 

func (x *Authentication_Request) Reset()

func (*Authentication_Request) String 

func (x *Authentication_Request) String() string

type Authentication_Response 

type Authentication_Response struct {

	// Types that are assignable to Value:
	//	*Authentication_Response_Success
	//	*Authentication_Response_Failure
	Value isAuthentication_Response_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Authentication_Response) Descriptor deprecated 

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

Deprecated: Use Authentication_Response.ProtoReflect.Descriptor instead.

func (*Authentication_Response) GetFailure 

func (x *Authentication_Response) GetFailure() *Authentication_Failure

func (*Authentication_Response) GetSuccess 

func (x *Authentication_Response) GetSuccess() *Authentication_Success

func (*Authentication_Response) GetValue 

func (m *Authentication_Response) GetValue() isAuthentication_Response_Value

func (*Authentication_Response) ProtoMessage 

func (*Authentication_Response) ProtoMessage()

func (*Authentication_Response) ProtoReflect 

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

func (*Authentication_Response) Reset 

func (x *Authentication_Response) Reset()

func (*Authentication_Response) String 

func (x *Authentication_Response) String() string

type Authentication_Response_Failure 

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

type Authentication_Response_Success 

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

type Authentication_Success 

type Authentication_Success struct {
	Token     []byte                 `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Authentication_Success) Descriptor deprecated 

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

Deprecated: Use Authentication_Success.ProtoReflect.Descriptor instead.

func (*Authentication_Success) GetExpiresAt 

func (x *Authentication_Success) GetExpiresAt() *timestamppb.Timestamp

func (*Authentication_Success) GetToken 

func (x *Authentication_Success) GetToken() []byte

func (*Authentication_Success) ProtoMessage 

func (*Authentication_Success) ProtoMessage()

func (*Authentication_Success) ProtoReflect 

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

func (*Authentication_Success) Reset 

func (x *Authentication_Success) Reset()

func (*Authentication_Success) String 

func (x *Authentication_Success) String() string

type AwaitTimeRequest 

type AwaitTimeRequest struct {

	// optional - must be specified for participants but can be defaulted for domain entities as they only have one possible domain
	DomainId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	// the domain time to wait for
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*AwaitTimeRequest) Descriptor deprecated 

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

Deprecated: Use AwaitTimeRequest.ProtoReflect.Descriptor instead.

func (*AwaitTimeRequest) GetDomainId 

func (x *AwaitTimeRequest) GetDomainId() *wrapperspb.StringValue

func (*AwaitTimeRequest) GetTimestamp 

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

func (*AwaitTimeRequest) ProtoMessage 

func (*AwaitTimeRequest) ProtoMessage()

func (*AwaitTimeRequest) ProtoReflect 

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

func (*AwaitTimeRequest) Reset 

func (x *AwaitTimeRequest) Reset()

func (*AwaitTimeRequest) String 

func (x *AwaitTimeRequest) String() string

type Challenge 

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

func (*Challenge) Descriptor deprecated 

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

Deprecated: Use Challenge.ProtoReflect.Descriptor instead.

func (*Challenge) ProtoMessage 

func (*Challenge) ProtoMessage()

func (*Challenge) ProtoReflect 

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

func (*Challenge) Reset 

func (x *Challenge) Reset()

func (*Challenge) String 

func (x *Challenge) String() string

type Challenge_Failure 

type Challenge_Failure struct {
	Code   uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Challenge_Failure) Descriptor deprecated 

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

Deprecated: Use Challenge_Failure.ProtoReflect.Descriptor instead.

func (*Challenge_Failure) GetCode 

func (x *Challenge_Failure) GetCode() uint32

func (*Challenge_Failure) GetReason 

func (x *Challenge_Failure) GetReason() string

func (*Challenge_Failure) ProtoMessage 

func (*Challenge_Failure) ProtoMessage()

func (*Challenge_Failure) ProtoReflect 

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

func (*Challenge_Failure) Reset 

func (x *Challenge_Failure) Reset()

func (*Challenge_Failure) String 

func (x *Challenge_Failure) String() string

type Challenge_Request 

type Challenge_Request struct {
	Member                 string   `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	MemberProtocolVersions []string `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Challenge_Request) Descriptor deprecated 

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

Deprecated: Use Challenge_Request.ProtoReflect.Descriptor instead.

func (*Challenge_Request) GetMember 

func (x *Challenge_Request) GetMember() string

func (*Challenge_Request) GetMemberProtocolVersions 

func (x *Challenge_Request) GetMemberProtocolVersions() []string

func (*Challenge_Request) ProtoMessage 

func (*Challenge_Request) ProtoMessage()

func (*Challenge_Request) ProtoReflect 

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

func (*Challenge_Request) Reset 

func (x *Challenge_Request) Reset()

func (*Challenge_Request) String 

func (x *Challenge_Request) String() string

type Challenge_Response 

type Challenge_Response struct {

	// Types that are assignable to Value:
	//	*Challenge_Response_Success
	//	*Challenge_Response_Failure
	Value isChallenge_Response_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*Challenge_Response) Descriptor deprecated 

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

Deprecated: Use Challenge_Response.ProtoReflect.Descriptor instead.

func (*Challenge_Response) GetFailure 

func (x *Challenge_Response) GetFailure() *Challenge_Failure

func (*Challenge_Response) GetSuccess 

func (x *Challenge_Response) GetSuccess() *Challenge_Success

func (*Challenge_Response) GetValue 

func (m *Challenge_Response) GetValue() isChallenge_Response_Value

func (*Challenge_Response) ProtoMessage 

func (*Challenge_Response) ProtoMessage()

func (*Challenge_Response) ProtoReflect 

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

func (*Challenge_Response) Reset 

func (x *Challenge_Response) Reset()

func (*Challenge_Response) String 

func (x *Challenge_Response) String() string

type Challenge_Response_Failure 

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

type Challenge_Response_Success 

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

type Challenge_Success 

type Challenge_Success struct {
	DomainVersion string `protobuf:"bytes,1,opt,name=domain_version,json=domainVersion,proto3" json:"domain_version,omitempty"`
	// random nonce to be used for authentication
	Nonce []byte `protobuf:"bytes,2,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// fingerprints of the possible keys the domain expects the member to use for authentication
	// (many are supplied in case there are many instances running on behalf of the member that only have access to a subset of the registered keys)
	Fingerprints []string `protobuf:"bytes,3,rep,name=fingerprints,proto3" json:"fingerprints,omitempty"`
	// contains filtered or unexported fields
}

func (*Challenge_Success) Descriptor deprecated 

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

Deprecated: Use Challenge_Success.ProtoReflect.Descriptor instead.

func (*Challenge_Success) GetDomainVersion 

func (x *Challenge_Success) GetDomainVersion() string

func (*Challenge_Success) GetFingerprints 

func (x *Challenge_Success) GetFingerprints() []string

func (*Challenge_Success) GetNonce 

func (x *Challenge_Success) GetNonce() []byte

func (*Challenge_Success) ProtoMessage 

func (*Challenge_Success) ProtoMessage()

func (*Challenge_Success) ProtoReflect 

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

func (*Challenge_Success) Reset 

func (x *Challenge_Success) Reset()

func (*Challenge_Success) String 

func (x *Challenge_Success) String() string

type DomainServiceClient deprecated 

type DomainServiceClient interface {
	GetServiceAgreement(ctx context.Context, in *GetServiceAgreementRequest, opts ...grpc.CallOption) (*GetServiceAgreementResponse, 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.

Deprecated: Do not use.

func NewDomainServiceClient deprecated 

func NewDomainServiceClient(cc grpc.ClientConnInterface) DomainServiceClient

Deprecated: Do not use.

type DomainServiceServer deprecated 

type DomainServiceServer interface {
	GetServiceAgreement(context.Context, *GetServiceAgreementRequest) (*GetServiceAgreementResponse, error)
	// contains filtered or unexported methods
}

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

Deprecated: Do not use.

type DomainTimeServiceClient 

type DomainTimeServiceClient interface {
	// fetch the domain time which has been received within a supplied freshness bound defined by the local clock
	FetchTime(ctx context.Context, in *FetchTimeRequest, opts ...grpc.CallOption) (*FetchTimeResponse, error)
	// await for the supplied time to be reached on the target domain
	AwaitTime(ctx context.Context, in *AwaitTimeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

DomainTimeServiceClient is the client API for DomainTimeService 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 NewDomainTimeServiceClient 

func NewDomainTimeServiceClient(cc grpc.ClientConnInterface) DomainTimeServiceClient

type DomainTimeServiceServer 

type DomainTimeServiceServer interface {
	// fetch the domain time which has been received within a supplied freshness bound defined by the local clock
	FetchTime(context.Context, *FetchTimeRequest) (*FetchTimeResponse, error)
	// await for the supplied time to be reached on the target domain
	AwaitTime(context.Context, *AwaitTimeRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

DomainTimeServiceServer is the server API for DomainTimeService service. All implementations must embed UnimplementedDomainTimeServiceServer for forward compatibility

type FetchTimeRequest 

type FetchTimeRequest struct {

	// optional - must be specified for participants but can be defaulted for domain entities as they only have one possible domain
	DomainId       *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	FreshnessBound *durationpb.Duration    `protobuf:"bytes,2,opt,name=freshness_bound,json=freshnessBound,proto3" json:"freshness_bound,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTimeRequest) Descriptor deprecated 

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

Deprecated: Use FetchTimeRequest.ProtoReflect.Descriptor instead.

func (*FetchTimeRequest) GetDomainId 

func (x *FetchTimeRequest) GetDomainId() *wrapperspb.StringValue

func (*FetchTimeRequest) GetFreshnessBound 

func (x *FetchTimeRequest) GetFreshnessBound() *durationpb.Duration

func (*FetchTimeRequest) ProtoMessage 

func (*FetchTimeRequest) ProtoMessage()

func (*FetchTimeRequest) ProtoReflect 

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

func (*FetchTimeRequest) Reset 

func (x *FetchTimeRequest) Reset()

func (*FetchTimeRequest) String 

func (x *FetchTimeRequest) String() string

type FetchTimeResponse 

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

func (*FetchTimeResponse) Descriptor deprecated 

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

Deprecated: Use FetchTimeResponse.ProtoReflect.Descriptor instead.

func (*FetchTimeResponse) GetTimestamp 

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

func (*FetchTimeResponse) ProtoMessage 

func (*FetchTimeResponse) ProtoMessage()

func (*FetchTimeResponse) ProtoReflect 

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

func (*FetchTimeResponse) Reset 

func (x *FetchTimeResponse) Reset()

func (*FetchTimeResponse) String 

func (x *FetchTimeResponse) String() string

type GetServiceAgreementRequest 

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

func (*GetServiceAgreementRequest) Descriptor deprecated 

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

Deprecated: Use GetServiceAgreementRequest.ProtoReflect.Descriptor instead.

func (*GetServiceAgreementRequest) ProtoMessage 

func (*GetServiceAgreementRequest) ProtoMessage()

func (*GetServiceAgreementRequest) ProtoReflect 

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

func (*GetServiceAgreementRequest) Reset 

func (x *GetServiceAgreementRequest) Reset()

func (*GetServiceAgreementRequest) String 

func (x *GetServiceAgreementRequest) String() string

type GetServiceAgreementResponse 

type GetServiceAgreementResponse struct {
	Agreement *v0.ServiceAgreement `protobuf:"bytes,1,opt,name=agreement,proto3" json:"agreement,omitempty"` // Optional, present if the domain requires a service agreement
	// contains filtered or unexported fields
}

func (*GetServiceAgreementResponse) Descriptor deprecated 

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

Deprecated: Use GetServiceAgreementResponse.ProtoReflect.Descriptor instead.

func (*GetServiceAgreementResponse) GetAgreement 

func (x *GetServiceAgreementResponse) GetAgreement() *v0.ServiceAgreement

func (*GetServiceAgreementResponse) ProtoMessage 

func (*GetServiceAgreementResponse) ProtoMessage()

func (*GetServiceAgreementResponse) ProtoReflect 

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

func (*GetServiceAgreementResponse) Reset 

func (x *GetServiceAgreementResponse) Reset()

func (*GetServiceAgreementResponse) String 

func (x *GetServiceAgreementResponse) String() string

type SendAsyncResponse 

type SendAsyncResponse struct {
	Error *SendAsyncResponse_Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // Defined iff the response is an error.
	// contains filtered or unexported fields
}

func (*SendAsyncResponse) Descriptor deprecated 

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

Deprecated: Use SendAsyncResponse.ProtoReflect.Descriptor instead.

func (*SendAsyncResponse) GetError 

func (x *SendAsyncResponse) GetError() *SendAsyncResponse_Error

func (*SendAsyncResponse) ProtoMessage 

func (*SendAsyncResponse) ProtoMessage()

func (*SendAsyncResponse) ProtoReflect 

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

func (*SendAsyncResponse) Reset 

func (x *SendAsyncResponse) Reset()

func (*SendAsyncResponse) String 

func (x *SendAsyncResponse) String() string

type SendAsyncResponse_Error 

type SendAsyncResponse_Error struct {

	// Types that are assignable to Reason:
	//	*SendAsyncResponse_Error_RequestInvalid
	//	*SendAsyncResponse_Error_RequestRefused
	//	*SendAsyncResponse_Error_Overloaded
	//	*SendAsyncResponse_Error_SenderUnknown
	//	*SendAsyncResponse_Error_ShuttingDown
	//	*SendAsyncResponse_Error_Unavailable
	//	*SendAsyncResponse_Error_UnknownRecipients
	Reason isSendAsyncResponse_Error_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

func (*SendAsyncResponse_Error) Descriptor deprecated 

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

Deprecated: Use SendAsyncResponse_Error.ProtoReflect.Descriptor instead.

func (*SendAsyncResponse_Error) GetOverloaded 

func (x *SendAsyncResponse_Error) GetOverloaded() string

func (*SendAsyncResponse_Error) GetReason 

func (m *SendAsyncResponse_Error) GetReason() isSendAsyncResponse_Error_Reason

func (*SendAsyncResponse_Error) GetRequestInvalid 

func (x *SendAsyncResponse_Error) GetRequestInvalid() string

func (*SendAsyncResponse_Error) GetRequestRefused 

func (x *SendAsyncResponse_Error) GetRequestRefused() string

func (*SendAsyncResponse_Error) GetSenderUnknown 

func (x *SendAsyncResponse_Error) GetSenderUnknown() string

func (*SendAsyncResponse_Error) GetShuttingDown 

func (x *SendAsyncResponse_Error) GetShuttingDown() string

func (*SendAsyncResponse_Error) GetUnavailable 

func (x *SendAsyncResponse_Error) GetUnavailable() string

func (*SendAsyncResponse_Error) GetUnknownRecipients 

func (x *SendAsyncResponse_Error) GetUnknownRecipients() string

func (*SendAsyncResponse_Error) ProtoMessage 

func (*SendAsyncResponse_Error) ProtoMessage()

func (*SendAsyncResponse_Error) ProtoReflect 

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

func (*SendAsyncResponse_Error) Reset 

func (x *SendAsyncResponse_Error) Reset()

func (*SendAsyncResponse_Error) String 

func (x *SendAsyncResponse_Error) String() string

type SendAsyncResponse_Error_Overloaded 

type SendAsyncResponse_Error_Overloaded struct {
	// The sequencer is overloaded and does not have capacity to handle this request.
	Overloaded string `protobuf:"bytes,3,opt,name=overloaded,proto3,oneof"`
}

type SendAsyncResponse_Error_RequestInvalid 

type SendAsyncResponse_Error_RequestInvalid struct {
	// The sequencer couldn't read the request (typically indicates a serialization and/or versioning bug).
	RequestInvalid string `protobuf:"bytes,1,opt,name=request_invalid,json=requestInvalid,proto3,oneof"`
}

type SendAsyncResponse_Error_RequestRefused 

type SendAsyncResponse_Error_RequestRefused struct {
	// The sequencer could read the request but refused to handle it (the request may violate a max size constraint).
	RequestRefused string `protobuf:"bytes,2,opt,name=request_refused,json=requestRefused,proto3,oneof"`
}

type SendAsyncResponse_Error_SenderUnknown 

type SendAsyncResponse_Error_SenderUnknown struct {
	// The specified sender is not registered so the sequencer cannot guarantee publishing a Deliver event if the request can be sequenced.
	SenderUnknown string `protobuf:"bytes,4,opt,name=sender_unknown,json=senderUnknown,proto3,oneof"`
}

type SendAsyncResponse_Error_ShuttingDown 

type SendAsyncResponse_Error_ShuttingDown struct {
	// The sequencer is shutting down so is declining to process new requests
	ShuttingDown string `protobuf:"bytes,5,opt,name=shutting_down,json=shuttingDown,proto3,oneof"`
}

type SendAsyncResponse_Error_Unavailable 

type SendAsyncResponse_Error_Unavailable struct {
	// The sequencer is unavailable and can't currently process requests
	Unavailable string `protobuf:"bytes,6,opt,name=unavailable,proto3,oneof"`
}

type SendAsyncResponse_Error_UnknownRecipients 

type SendAsyncResponse_Error_UnknownRecipients struct {
	// There are one or more recipients that are not registered so the sequencer cannot guarantee publishing a Deliver event if the request can be sequenced.
	// This message was added in protocol version 1.1, therefore it must not be used by a sequencer operating on Canton 1.0 protocol version.
	UnknownRecipients string `protobuf:"bytes,7,opt,name=unknown_recipients,json=unknownRecipients,proto3,oneof"`
}

type SendAsyncSignedResponse 

type SendAsyncSignedResponse struct {
	Error *SendAsyncSignedResponse_Error `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"` // Defined iff the response is an error.
	// contains filtered or unexported fields
}

Changes compared to SendAsyncResponse: added `Internal` and `Generic`. Note: `Generic` is not used yet, it is introduced for upgradability purposes.

func (*SendAsyncSignedResponse) Descriptor deprecated 

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

Deprecated: Use SendAsyncSignedResponse.ProtoReflect.Descriptor instead.

func (*SendAsyncSignedResponse) GetError 

func (x *SendAsyncSignedResponse) GetError() *SendAsyncSignedResponse_Error

func (*SendAsyncSignedResponse) ProtoMessage 

func (*SendAsyncSignedResponse) ProtoMessage()

func (*SendAsyncSignedResponse) ProtoReflect 

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

func (*SendAsyncSignedResponse) Reset 

func (x *SendAsyncSignedResponse) Reset()

func (*SendAsyncSignedResponse) String 

func (x *SendAsyncSignedResponse) String() string

type SendAsyncSignedResponse_Error 

type SendAsyncSignedResponse_Error struct {

	// Types that are assignable to Reason:
	//	*SendAsyncSignedResponse_Error_RequestInvalid
	//	*SendAsyncSignedResponse_Error_RequestRefused
	//	*SendAsyncSignedResponse_Error_Overloaded
	//	*SendAsyncSignedResponse_Error_SenderUnknown
	//	*SendAsyncSignedResponse_Error_ShuttingDown
	//	*SendAsyncSignedResponse_Error_Unavailable
	//	*SendAsyncSignedResponse_Error_UnknownRecipients
	//	*SendAsyncSignedResponse_Error_Internal
	//	*SendAsyncSignedResponse_Error_Generic
	Reason isSendAsyncSignedResponse_Error_Reason `protobuf_oneof:"reason"`
	// contains filtered or unexported fields
}

func (*SendAsyncSignedResponse_Error) Descriptor deprecated 

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

Deprecated: Use SendAsyncSignedResponse_Error.ProtoReflect.Descriptor instead.

func (*SendAsyncSignedResponse_Error) GetGeneric 

func (x *SendAsyncSignedResponse_Error) GetGeneric() string

func (*SendAsyncSignedResponse_Error) GetInternal 

func (x *SendAsyncSignedResponse_Error) GetInternal() string

func (*SendAsyncSignedResponse_Error) GetOverloaded 

func (x *SendAsyncSignedResponse_Error) GetOverloaded() string

func (*SendAsyncSignedResponse_Error) GetReason 

func (m *SendAsyncSignedResponse_Error) GetReason() isSendAsyncSignedResponse_Error_Reason

func (*SendAsyncSignedResponse_Error) GetRequestInvalid 

func (x *SendAsyncSignedResponse_Error) GetRequestInvalid() string

func (*SendAsyncSignedResponse_Error) GetRequestRefused 

func (x *SendAsyncSignedResponse_Error) GetRequestRefused() string

func (*SendAsyncSignedResponse_Error) GetSenderUnknown 

func (x *SendAsyncSignedResponse_Error) GetSenderUnknown() string

func (*SendAsyncSignedResponse_Error) GetShuttingDown 

func (x *SendAsyncSignedResponse_Error) GetShuttingDown() string

func (*SendAsyncSignedResponse_Error) GetUnavailable 

func (x *SendAsyncSignedResponse_Error) GetUnavailable() string

func (*SendAsyncSignedResponse_Error) GetUnknownRecipients 

func (x *SendAsyncSignedResponse_Error) GetUnknownRecipients() string

func (*SendAsyncSignedResponse_Error) ProtoMessage 

func (*SendAsyncSignedResponse_Error) ProtoMessage()

func (*SendAsyncSignedResponse_Error) ProtoReflect 

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

func (*SendAsyncSignedResponse_Error) Reset 

func (x *SendAsyncSignedResponse_Error) Reset()

func (*SendAsyncSignedResponse_Error) String 

func (x *SendAsyncSignedResponse_Error) String() string

type SendAsyncSignedResponse_Error_Generic 

type SendAsyncSignedResponse_Error_Generic struct {
	// Generic error
	Generic string `protobuf:"bytes,9,opt,name=generic,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_Internal 

type SendAsyncSignedResponse_Error_Internal struct {
	// Can be used for internal errors. For example if the sequencer is not able to get dynamic parameters from the latest snapshot.
	Internal string `protobuf:"bytes,8,opt,name=internal,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_Overloaded 

type SendAsyncSignedResponse_Error_Overloaded struct {
	// The sequencer is overloaded and does not have capacity to handle this request.
	Overloaded string `protobuf:"bytes,3,opt,name=overloaded,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_RequestInvalid 

type SendAsyncSignedResponse_Error_RequestInvalid struct {
	// The sequencer couldn't read the request (typically indicates a serialization and/or versioning bug).
	RequestInvalid string `protobuf:"bytes,1,opt,name=request_invalid,json=requestInvalid,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_RequestRefused 

type SendAsyncSignedResponse_Error_RequestRefused struct {
	// The sequencer could read the request but refused to handle it (the request may violate a max size constraint).
	RequestRefused string `protobuf:"bytes,2,opt,name=request_refused,json=requestRefused,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_SenderUnknown 

type SendAsyncSignedResponse_Error_SenderUnknown struct {
	// The specified sender is not registered so the sequencer cannot guarantee publishing a Deliver event if the request can be sequenced.
	SenderUnknown string `protobuf:"bytes,4,opt,name=sender_unknown,json=senderUnknown,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_ShuttingDown 

type SendAsyncSignedResponse_Error_ShuttingDown struct {
	// The sequencer is shutting down so is declining to process new requests
	ShuttingDown string `protobuf:"bytes,5,opt,name=shutting_down,json=shuttingDown,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_Unavailable 

type SendAsyncSignedResponse_Error_Unavailable struct {
	// The sequencer is unavailable and can't currently process requests
	Unavailable string `protobuf:"bytes,6,opt,name=unavailable,proto3,oneof"`
}

type SendAsyncSignedResponse_Error_UnknownRecipients 

type SendAsyncSignedResponse_Error_UnknownRecipients struct {
	// There are one or more recipients that are not registered so the sequencer cannot guarantee publishing a Deliver event if the request can be sequenced.
	// This message was added in Canton 2.1, therefore it must not be used by a sequencer operating on Canton 1.0.
	UnknownRecipients string `protobuf:"bytes,7,opt,name=unknown_recipients,json=unknownRecipients,proto3,oneof"`
}

type SendAsyncUnauthenticatedVersionedRequest 

type SendAsyncUnauthenticatedVersionedRequest struct {

	// Contains a versioned SubmissionRequest of v0 or higher.
	SubmissionRequest []byte `protobuf:"bytes,1,opt,name=submission_request,json=submissionRequest,proto3" json:"submission_request,omitempty"`
	// contains filtered or unexported fields
}

func (*SendAsyncUnauthenticatedVersionedRequest) Descriptor deprecated 

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

Deprecated: Use SendAsyncUnauthenticatedVersionedRequest.ProtoReflect.Descriptor instead.

func (*SendAsyncUnauthenticatedVersionedRequest) GetSubmissionRequest 

func (x *SendAsyncUnauthenticatedVersionedRequest) GetSubmissionRequest() []byte

func (*SendAsyncUnauthenticatedVersionedRequest) ProtoMessage 

func (*SendAsyncUnauthenticatedVersionedRequest) ProtoMessage()

func (*SendAsyncUnauthenticatedVersionedRequest) ProtoReflect 

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

func (*SendAsyncUnauthenticatedVersionedRequest) Reset 

func (x *SendAsyncUnauthenticatedVersionedRequest) Reset()

func (*SendAsyncUnauthenticatedVersionedRequest) String 

func (x *SendAsyncUnauthenticatedVersionedRequest) String() string

type SendAsyncVersionedRequest 

type SendAsyncVersionedRequest struct {

	// Contains a versioned SignedContent of v0 or higher
	// which itself contains a versioned SubmissionRequest of v0 or higher.
	SignedSubmissionRequest []byte `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SendAsyncVersionedRequest) Descriptor deprecated 

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

Deprecated: Use SendAsyncVersionedRequest.ProtoReflect.Descriptor instead.

func (*SendAsyncVersionedRequest) GetSignedSubmissionRequest 

func (x *SendAsyncVersionedRequest) GetSignedSubmissionRequest() []byte

func (*SendAsyncVersionedRequest) ProtoMessage 

func (*SendAsyncVersionedRequest) ProtoMessage()

func (*SendAsyncVersionedRequest) ProtoReflect 

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

func (*SendAsyncVersionedRequest) Reset 

func (x *SendAsyncVersionedRequest) Reset()

func (*SendAsyncVersionedRequest) String 

func (x *SendAsyncVersionedRequest) String() string

type SequencedEventTrafficState 

type SequencedEventTrafficState struct {

	// Remaining extra traffic at the time of this event
	ExtraTrafficRemainder uint64 `` /* 127-byte string literal not displayed */
	// Total extra traffic consumed at the time of this event
	ExtraTrafficConsumed uint64 `protobuf:"varint,3,opt,name=extra_traffic_consumed,json=extraTrafficConsumed,proto3" json:"extra_traffic_consumed,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencedEventTrafficState) Descriptor deprecated 

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

Deprecated: Use SequencedEventTrafficState.ProtoReflect.Descriptor instead.

func (*SequencedEventTrafficState) GetExtraTrafficConsumed 

func (x *SequencedEventTrafficState) GetExtraTrafficConsumed() uint64

func (*SequencedEventTrafficState) GetExtraTrafficRemainder 

func (x *SequencedEventTrafficState) GetExtraTrafficRemainder() uint64

func (*SequencedEventTrafficState) ProtoMessage 

func (*SequencedEventTrafficState) ProtoMessage()

func (*SequencedEventTrafficState) ProtoReflect 

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

func (*SequencedEventTrafficState) Reset 

func (x *SequencedEventTrafficState) Reset()

func (*SequencedEventTrafficState) String 

func (x *SequencedEventTrafficState) String() string

type SequencerApiType 

type SequencerApiType int32
const (
	SequencerApiType_Grpc SequencerApiType = 0
)

func (SequencerApiType) Descriptor 

func (SequencerApiType) Descriptor() protoreflect.EnumDescriptor

func (SequencerApiType) Enum 

func (x SequencerApiType) Enum() *SequencerApiType

func (SequencerApiType) EnumDescriptor deprecated 

func (SequencerApiType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SequencerApiType.Descriptor instead.

func (SequencerApiType) Number 

func (x SequencerApiType) Number() protoreflect.EnumNumber

func (SequencerApiType) String 

func (x SequencerApiType) String() string

func (SequencerApiType) Type 

func (SequencerApiType) Type() protoreflect.EnumType

type SequencerAuthenticationServiceClient 

type SequencerAuthenticationServiceClient interface {
	// If provided with a supported protocol version and crypto type,
	// will return a nonce and fingerprint of the expected key to sign this nonce
	Challenge(ctx context.Context, in *Challenge_Request, opts ...grpc.CallOption) (*Challenge_Response, error)
	// If provided with a correctly signed nonce, will return a authentication token
	// to be supplied to SequencerService operations
	Authenticate(ctx context.Context, in *Authentication_Request, opts ...grpc.CallOption) (*Authentication_Response, error)
}

SequencerAuthenticationServiceClient is the client API for SequencerAuthenticationService 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 NewSequencerAuthenticationServiceClient 

func NewSequencerAuthenticationServiceClient(cc grpc.ClientConnInterface) SequencerAuthenticationServiceClient

type SequencerAuthenticationServiceServer 

type SequencerAuthenticationServiceServer interface {
	// If provided with a supported protocol version and crypto type,
	// will return a nonce and fingerprint of the expected key to sign this nonce
	Challenge(context.Context, *Challenge_Request) (*Challenge_Response, error)
	// If provided with a correctly signed nonce, will return a authentication token
	// to be supplied to SequencerService operations
	Authenticate(context.Context, *Authentication_Request) (*Authentication_Response, error)
	// contains filtered or unexported methods
}

SequencerAuthenticationServiceServer is the server API for SequencerAuthenticationService service. All implementations must embed UnimplementedSequencerAuthenticationServiceServer for forward compatibility

type SequencerConnect 

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

func (*SequencerConnect) Descriptor deprecated 

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

Deprecated: Use SequencerConnect.ProtoReflect.Descriptor instead.

func (*SequencerConnect) ProtoMessage 

func (*SequencerConnect) ProtoMessage()

func (*SequencerConnect) ProtoReflect 

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

func (*SequencerConnect) Reset 

func (x *SequencerConnect) Reset()

func (*SequencerConnect) String 

func (x *SequencerConnect) String() string

type SequencerConnectServiceClient 

type SequencerConnectServiceClient interface {
	Handshake(ctx context.Context, in *v0.Handshake_Request, opts ...grpc.CallOption) (*v0.Handshake_Response, error)
	GetDomainId(ctx context.Context, in *SequencerConnect_GetDomainId_Request, opts ...grpc.CallOption) (*SequencerConnect_GetDomainId_Response, error)
	GetDomainParameters(ctx context.Context, in *SequencerConnect_GetDomainParameters_Request, opts ...grpc.CallOption) (*SequencerConnect_GetDomainParameters_Response, error)
	VerifyActive(ctx context.Context, in *SequencerConnect_VerifyActive_Request, opts ...grpc.CallOption) (*SequencerConnect_VerifyActive_Response, error)
	GetServiceAgreement(ctx context.Context, in *GetServiceAgreementRequest, opts ...grpc.CallOption) (*GetServiceAgreementResponse, error)
}

SequencerConnectServiceClient is the client API for SequencerConnectService 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 NewSequencerConnectServiceClient 

func NewSequencerConnectServiceClient(cc grpc.ClientConnInterface) SequencerConnectServiceClient

type SequencerConnectServiceServer 

type SequencerConnectServiceServer interface {
	Handshake(context.Context, *v0.Handshake_Request) (*v0.Handshake_Response, error)
	GetDomainId(context.Context, *SequencerConnect_GetDomainId_Request) (*SequencerConnect_GetDomainId_Response, error)
	GetDomainParameters(context.Context, *SequencerConnect_GetDomainParameters_Request) (*SequencerConnect_GetDomainParameters_Response, error)
	VerifyActive(context.Context, *SequencerConnect_VerifyActive_Request) (*SequencerConnect_VerifyActive_Response, error)
	GetServiceAgreement(context.Context, *GetServiceAgreementRequest) (*GetServiceAgreementResponse, error)
	// contains filtered or unexported methods
}

SequencerConnectServiceServer is the server API for SequencerConnectService service. All implementations must embed UnimplementedSequencerConnectServiceServer for forward compatibility

type SequencerConnect_GetDomainId 

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

func (*SequencerConnect_GetDomainId) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainId.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainId) ProtoMessage 

func (*SequencerConnect_GetDomainId) ProtoMessage()

func (*SequencerConnect_GetDomainId) ProtoReflect 

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

func (*SequencerConnect_GetDomainId) Reset 

func (x *SequencerConnect_GetDomainId) Reset()

func (*SequencerConnect_GetDomainId) String 

func (x *SequencerConnect_GetDomainId) String() string

type SequencerConnect_GetDomainId_Request 

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

func (*SequencerConnect_GetDomainId_Request) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainId_Request.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainId_Request) ProtoMessage 

func (*SequencerConnect_GetDomainId_Request) ProtoMessage()

func (*SequencerConnect_GetDomainId_Request) ProtoReflect 

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

func (*SequencerConnect_GetDomainId_Request) Reset 

func (x *SequencerConnect_GetDomainId_Request) Reset()

func (*SequencerConnect_GetDomainId_Request) String 

func (x *SequencerConnect_GetDomainId_Request) String() string

type SequencerConnect_GetDomainId_Response 

type SequencerConnect_GetDomainId_Response struct {
	DomainId string `protobuf:"bytes,1,opt,name=domain_id,json=domainId,proto3" json:"domain_id,omitempty"`
	// If `sequencer_id` is an empty string, consumers of this API can assume
	// that `domain_id` serves as the `sequencer_id`.
	SequencerId string `protobuf:"bytes,2,opt,name=sequencer_id,json=sequencerId,proto3" json:"sequencer_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerConnect_GetDomainId_Response) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainId_Response.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainId_Response) GetDomainId 

func (x *SequencerConnect_GetDomainId_Response) GetDomainId() string

func (*SequencerConnect_GetDomainId_Response) GetSequencerId 

func (x *SequencerConnect_GetDomainId_Response) GetSequencerId() string

func (*SequencerConnect_GetDomainId_Response) ProtoMessage 

func (*SequencerConnect_GetDomainId_Response) ProtoMessage()

func (*SequencerConnect_GetDomainId_Response) ProtoReflect 

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

func (*SequencerConnect_GetDomainId_Response) Reset 

func (x *SequencerConnect_GetDomainId_Response) Reset()

func (*SequencerConnect_GetDomainId_Response) String 

func (x *SequencerConnect_GetDomainId_Response) String() string

type SequencerConnect_GetDomainParameters 

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

func (*SequencerConnect_GetDomainParameters) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainParameters.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainParameters) ProtoMessage 

func (*SequencerConnect_GetDomainParameters) ProtoMessage()

func (*SequencerConnect_GetDomainParameters) ProtoReflect 

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

func (*SequencerConnect_GetDomainParameters) Reset 

func (x *SequencerConnect_GetDomainParameters) Reset()

func (*SequencerConnect_GetDomainParameters) String 

func (x *SequencerConnect_GetDomainParameters) String() string

type SequencerConnect_GetDomainParameters_Request 

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

func (*SequencerConnect_GetDomainParameters_Request) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainParameters_Request.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainParameters_Request) ProtoMessage 

func (*SequencerConnect_GetDomainParameters_Request) ProtoMessage()

func (*SequencerConnect_GetDomainParameters_Request) ProtoReflect 

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

func (*SequencerConnect_GetDomainParameters_Request) Reset 

func (x *SequencerConnect_GetDomainParameters_Request) Reset()

func (*SequencerConnect_GetDomainParameters_Request) String 

func (x *SequencerConnect_GetDomainParameters_Request) String() string

type SequencerConnect_GetDomainParameters_Response 

type SequencerConnect_GetDomainParameters_Response struct {

	// Types that are assignable to Parameters:
	//	*SequencerConnect_GetDomainParameters_Response_ParametersV0
	//	*SequencerConnect_GetDomainParameters_Response_ParametersV1
	Parameters isSequencerConnect_GetDomainParameters_Response_Parameters `protobuf_oneof:"parameters"`
	// contains filtered or unexported fields
}

func (*SequencerConnect_GetDomainParameters_Response) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_GetDomainParameters_Response.ProtoReflect.Descriptor instead.

func (*SequencerConnect_GetDomainParameters_Response) GetParameters 

func (m *SequencerConnect_GetDomainParameters_Response) GetParameters() isSequencerConnect_GetDomainParameters_Response_Parameters

func (*SequencerConnect_GetDomainParameters_Response) GetParametersV0 

func (x *SequencerConnect_GetDomainParameters_Response) GetParametersV0() *v0.StaticDomainParameters

func (*SequencerConnect_GetDomainParameters_Response) GetParametersV1 

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

func (*SequencerConnect_GetDomainParameters_Response) ProtoMessage 

func (*SequencerConnect_GetDomainParameters_Response) ProtoMessage()

func (*SequencerConnect_GetDomainParameters_Response) ProtoReflect 

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

func (*SequencerConnect_GetDomainParameters_Response) Reset 

func (x *SequencerConnect_GetDomainParameters_Response) Reset()

func (*SequencerConnect_GetDomainParameters_Response) String 

func (x *SequencerConnect_GetDomainParameters_Response) String() string

type SequencerConnect_GetDomainParameters_Response_ParametersV0 

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

type SequencerConnect_GetDomainParameters_Response_ParametersV1 

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

type SequencerConnect_VerifyActive 

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

func (*SequencerConnect_VerifyActive) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_VerifyActive.ProtoReflect.Descriptor instead.

func (*SequencerConnect_VerifyActive) ProtoMessage 

func (*SequencerConnect_VerifyActive) ProtoMessage()

func (*SequencerConnect_VerifyActive) ProtoReflect 

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

func (*SequencerConnect_VerifyActive) Reset 

func (x *SequencerConnect_VerifyActive) Reset()

func (*SequencerConnect_VerifyActive) String 

func (x *SequencerConnect_VerifyActive) String() string

type SequencerConnect_VerifyActive_Failure 

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

func (*SequencerConnect_VerifyActive_Failure) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_VerifyActive_Failure.ProtoReflect.Descriptor instead.

func (*SequencerConnect_VerifyActive_Failure) GetReason 

func (x *SequencerConnect_VerifyActive_Failure) GetReason() string

func (*SequencerConnect_VerifyActive_Failure) ProtoMessage 

func (*SequencerConnect_VerifyActive_Failure) ProtoMessage()

func (*SequencerConnect_VerifyActive_Failure) ProtoReflect 

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

func (*SequencerConnect_VerifyActive_Failure) Reset 

func (x *SequencerConnect_VerifyActive_Failure) Reset()

func (*SequencerConnect_VerifyActive_Failure) String 

func (x *SequencerConnect_VerifyActive_Failure) String() string

type SequencerConnect_VerifyActive_Request 

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

func (*SequencerConnect_VerifyActive_Request) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_VerifyActive_Request.ProtoReflect.Descriptor instead.

func (*SequencerConnect_VerifyActive_Request) ProtoMessage 

func (*SequencerConnect_VerifyActive_Request) ProtoMessage()

func (*SequencerConnect_VerifyActive_Request) ProtoReflect 

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

func (*SequencerConnect_VerifyActive_Request) Reset 

func (x *SequencerConnect_VerifyActive_Request) Reset()

func (*SequencerConnect_VerifyActive_Request) String 

func (x *SequencerConnect_VerifyActive_Request) String() string

type SequencerConnect_VerifyActive_Response 

type SequencerConnect_VerifyActive_Response struct {

	// Types that are assignable to Value:
	//	*SequencerConnect_VerifyActive_Response_Success
	//	*SequencerConnect_VerifyActive_Response_Failure
	Value isSequencerConnect_VerifyActive_Response_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*SequencerConnect_VerifyActive_Response) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_VerifyActive_Response.ProtoReflect.Descriptor instead.

func (*SequencerConnect_VerifyActive_Response) GetFailure 

func (x *SequencerConnect_VerifyActive_Response) GetFailure() *SequencerConnect_VerifyActive_Failure

func (*SequencerConnect_VerifyActive_Response) GetSuccess 

func (x *SequencerConnect_VerifyActive_Response) GetSuccess() *SequencerConnect_VerifyActive_Success

func (*SequencerConnect_VerifyActive_Response) GetValue 

func (m *SequencerConnect_VerifyActive_Response) GetValue() isSequencerConnect_VerifyActive_Response_Value

func (*SequencerConnect_VerifyActive_Response) ProtoMessage 

func (*SequencerConnect_VerifyActive_Response) ProtoMessage()

func (*SequencerConnect_VerifyActive_Response) ProtoReflect 

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

func (*SequencerConnect_VerifyActive_Response) Reset 

func (x *SequencerConnect_VerifyActive_Response) Reset()

func (*SequencerConnect_VerifyActive_Response) String 

func (x *SequencerConnect_VerifyActive_Response) String() string

type SequencerConnect_VerifyActive_Response_Failure 

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

type SequencerConnect_VerifyActive_Response_Success 

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

type SequencerConnect_VerifyActive_Success 

type SequencerConnect_VerifyActive_Success struct {
	IsActive bool `protobuf:"varint,1,opt,name=is_active,json=isActive,proto3" json:"is_active,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerConnect_VerifyActive_Success) Descriptor deprecated 

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

Deprecated: Use SequencerConnect_VerifyActive_Success.ProtoReflect.Descriptor instead.

func (*SequencerConnect_VerifyActive_Success) GetIsActive 

func (x *SequencerConnect_VerifyActive_Success) GetIsActive() bool

func (*SequencerConnect_VerifyActive_Success) ProtoMessage 

func (*SequencerConnect_VerifyActive_Success) ProtoMessage()

func (*SequencerConnect_VerifyActive_Success) ProtoReflect 

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

func (*SequencerConnect_VerifyActive_Success) Reset 

func (x *SequencerConnect_VerifyActive_Success) Reset()

func (*SequencerConnect_VerifyActive_Success) String 

func (x *SequencerConnect_VerifyActive_Success) String() string

type SequencerConnection 

type SequencerConnection struct {

	// Types that are assignable to Type:
	//	*SequencerConnection_Grpc_
	Type  isSequencerConnection_Type `protobuf_oneof:"type"`
	Alias string                     `protobuf:"bytes,3,opt,name=alias,proto3" json:"alias,omitempty"`
	// contains filtered or unexported fields
}

Client configuration for how members should connect to the sequencer of a domain.

func (*SequencerConnection) Descriptor deprecated 

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

Deprecated: Use SequencerConnection.ProtoReflect.Descriptor instead.

func (*SequencerConnection) GetAlias 

func (x *SequencerConnection) GetAlias() string

func (*SequencerConnection) GetGrpc 

func (x *SequencerConnection) GetGrpc() *SequencerConnection_Grpc

func (*SequencerConnection) GetType 

func (m *SequencerConnection) GetType() isSequencerConnection_Type

func (*SequencerConnection) ProtoMessage 

func (*SequencerConnection) ProtoMessage()

func (*SequencerConnection) ProtoReflect 

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

func (*SequencerConnection) Reset 

func (x *SequencerConnection) Reset()

func (*SequencerConnection) String 

func (x *SequencerConnection) String() string

type SequencerConnection_Grpc 

type SequencerConnection_Grpc struct {

	// connection information to sequencer (http[s]://<host>:<port>")
	Connections []string `protobuf:"bytes,1,rep,name=connections,proto3" json:"connections,omitempty"`
	// Should the connection use TLS?
	TransportSecurity       bool                   `protobuf:"varint,2,opt,name=transportSecurity,proto3" json:"transportSecurity,omitempty"`
	CustomTrustCertificates *wrapperspb.BytesValue `protobuf:"bytes,3,opt,name=customTrustCertificates,proto3" json:"customTrustCertificates,omitempty"`
	// contains filtered or unexported fields
}

func (*SequencerConnection_Grpc) Descriptor deprecated 

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

Deprecated: Use SequencerConnection_Grpc.ProtoReflect.Descriptor instead.

func (*SequencerConnection_Grpc) GetConnections 

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

func (*SequencerConnection_Grpc) GetCustomTrustCertificates 

func (x *SequencerConnection_Grpc) GetCustomTrustCertificates() *wrapperspb.BytesValue

func (*SequencerConnection_Grpc) GetTransportSecurity 

func (x *SequencerConnection_Grpc) GetTransportSecurity() bool

func (*SequencerConnection_Grpc) ProtoMessage 

func (*SequencerConnection_Grpc) ProtoMessage()

func (*SequencerConnection_Grpc) ProtoReflect 

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

func (*SequencerConnection_Grpc) Reset 

func (x *SequencerConnection_Grpc) Reset()

func (*SequencerConnection_Grpc) String 

func (x *SequencerConnection_Grpc) String() string

type SequencerConnection_Grpc_ 

type SequencerConnection_Grpc_ struct {
	Grpc *SequencerConnection_Grpc `protobuf:"bytes,2,opt,name=grpc,proto3,oneof"`
}

type SequencerServiceClient 

type SequencerServiceClient interface {
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send,
	// if the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	// Used in protocol version 3
	SendAsync(ctx context.Context, in *v0.SubmissionRequest, opts ...grpc.CallOption) (*SendAsyncResponse, error)
	// Newer version of request submission (for authenticated members).
	// To be active for protocol versions 4.
	// The argument here is a SubmissionRequest wrapped in SignedContent.
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// submission requests in multi-writer architectures where writers don't fully trust each other.
	//
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send,
	// if the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	SendAsyncSigned(ctx context.Context, in *v0.SignedContent, opts ...grpc.CallOption) (*SendAsyncSignedResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsync, except that this
	// meant to be used only by unauthenticated members for very specific operations that do not require authentication
	// such as requesting that a participant's topology data gets accepted by the topology manager
	// Used in protocol versions 3 and 4
	SendAsyncUnauthenticated(ctx context.Context, in *v0.SubmissionRequest, opts ...grpc.CallOption) (*SendAsyncResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send.
	// If the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	//
	//
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// submission requests in multi-writer architectures where writers don't fully trust each other.
	//
	// Used in protocol version 5 or higher
	SendAsyncVersioned(ctx context.Context, in *SendAsyncVersionedRequest, opts ...grpc.CallOption) (*SendAsyncSignedResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsyncVersioned, except that this
	// meant to be used only by unauthenticated members for very specific operations that do not require authentication
	// such as requesting that a participant's topology data gets accepted by the topology manager
	//
	// Used in protocol version 5 or higher
	SendAsyncUnauthenticatedVersioned(ctx context.Context, in *SendAsyncUnauthenticatedVersionedRequest, opts ...grpc.CallOption) (*SendAsyncResponse, error)
	// Establishes a stream with the server to receive sequenced events from the domain after the given
	// counter. The delivered events will have a sequential counter and monotonically increasing timestamp.
	// TBD: Message TTL - How far back should it go when the participant initiate a subscription ?
	Subscribe(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (SequencerService_SubscribeClient, error)
	// Same as `Subscribe(SubscriptionRequest)` but delivers byte array rather than typed
	// message to support multiple versions.
	SubscribeVersioned(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (SequencerService_SubscribeVersionedClient, error)
	// Establishes a stream with the server to receive sequenced events exactly like Subscribe, except that this is
	// supposed to be used only by unauthenticated members similarly to SendAsyncUnauthenticated
	SubscribeUnauthenticated(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (SequencerService_SubscribeUnauthenticatedClient, error)
	// Same as `SubscribeUnauthenticated(SubscriptionRequest)` but delivers byte array rather than typed
	// message to support multiple versions.
	SubscribeUnauthenticatedVersioned(ctx context.Context, in *SubscriptionRequest, opts ...grpc.CallOption) (SequencerService_SubscribeUnauthenticatedVersionedClient, error)
	// Allows a member to acknowledge that they have read all events up to and including the provided timestamp,
	// and that they will never re-read these events again. This information is currently only used for informational
	// purposes and to provide a watermark for which it is safe to prune earlier events from the sequencer data stores.
	// There is no requirement for every event to be individually acknowledged, and in fact callers are encouraged to
	// only periodically record acknowledgements (at an interval of minutes is expected to be more than sufficient for
	// pruning).
	Acknowledge(ctx context.Context, in *AcknowledgeRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// Newer version of acknowledgements.
	// To be active for protocol versions >= 4.
	// The argument here is an AcknowledgeRequest wrapped in SignedContent.
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// acknowledgements in multi-writer architectures where writers don't fully trust each other.
	//
	// Allows a member to acknowledge that they have read all events up to and including the provided timestamp,
	// and that they will never re-read these events again. This information is currently only used for informational
	// purposes and to provide a watermark for which it is safe to prune earlier events from the sequencer data stores.
	// There is no requirement for every event to be individually acknowledged, and in fact callers are encouraged to
	// only periodically record acknowledgements (at an interval of minutes is expected to be more than sufficient for
	// pruning).
	AcknowledgeSigned(ctx context.Context, in *v0.SignedContent, opts ...grpc.CallOption) (*emptypb.Empty, error)
	// TODO(#11255) use a streaming response to avoid running into the grpc message size limit
	DownloadTopologyStateForInit(ctx context.Context, in *TopologyStateForInitRequest, opts ...grpc.CallOption) (*TopologyStateForInitResponse, error)
}

SequencerServiceClient is the client API for SequencerService 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 NewSequencerServiceClient 

func NewSequencerServiceClient(cc grpc.ClientConnInterface) SequencerServiceClient

type SequencerServiceServer 

type SequencerServiceServer interface {
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send,
	// if the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	// Used in protocol version 3
	SendAsync(context.Context, *v0.SubmissionRequest) (*SendAsyncResponse, error)
	// Newer version of request submission (for authenticated members).
	// To be active for protocol versions 4.
	// The argument here is a SubmissionRequest wrapped in SignedContent.
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// submission requests in multi-writer architectures where writers don't fully trust each other.
	//
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send,
	// if the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	SendAsyncSigned(context.Context, *v0.SignedContent) (*SendAsyncSignedResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsync, except that this
	// meant to be used only by unauthenticated members for very specific operations that do not require authentication
	// such as requesting that a participant's topology data gets accepted by the topology manager
	// Used in protocol versions 3 and 4
	SendAsyncUnauthenticated(context.Context, *v0.SubmissionRequest) (*SendAsyncResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously.
	// The rpc request may return an error if the request cannot be processed at all - see SendAsyncResponse for these scenarios.
	// The sequencer may emit a Deliver or DeliverError event from this send.
	// If the subscriber witnesses an event greater or equal to the supplied maxSequencingTime, the sequencer
	// guarantees not to publish a future Deliver event for this send.
	// The sequencer implementation may however publish a future DeliverError (typically used to indicate maxSequencingTime exceeded).
	//
	//
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// submission requests in multi-writer architectures where writers don't fully trust each other.
	//
	// Used in protocol version 5 or higher
	SendAsyncVersioned(context.Context, *SendAsyncVersionedRequest) (*SendAsyncSignedResponse, error)
	// Submit a send request to the sequencer for sequencing asynchronously exactly like SendAsyncVersioned, except that this
	// meant to be used only by unauthenticated members for very specific operations that do not require authentication
	// such as requesting that a participant's topology data gets accepted by the topology manager
	//
	// Used in protocol version 5 or higher
	SendAsyncUnauthenticatedVersioned(context.Context, *SendAsyncUnauthenticatedVersionedRequest) (*SendAsyncResponse, error)
	// Establishes a stream with the server to receive sequenced events from the domain after the given
	// counter. The delivered events will have a sequential counter and monotonically increasing timestamp.
	// TBD: Message TTL - How far back should it go when the participant initiate a subscription ?
	Subscribe(*SubscriptionRequest, SequencerService_SubscribeServer) error
	// Same as `Subscribe(SubscriptionRequest)` but delivers byte array rather than typed
	// message to support multiple versions.
	SubscribeVersioned(*SubscriptionRequest, SequencerService_SubscribeVersionedServer) error
	// Establishes a stream with the server to receive sequenced events exactly like Subscribe, except that this is
	// supposed to be used only by unauthenticated members similarly to SendAsyncUnauthenticated
	SubscribeUnauthenticated(*SubscriptionRequest, SequencerService_SubscribeUnauthenticatedServer) error
	// Same as `SubscribeUnauthenticated(SubscriptionRequest)` but delivers byte array rather than typed
	// message to support multiple versions.
	SubscribeUnauthenticatedVersioned(*SubscriptionRequest, SequencerService_SubscribeUnauthenticatedVersionedServer) error
	// Allows a member to acknowledge that they have read all events up to and including the provided timestamp,
	// and that they will never re-read these events again. This information is currently only used for informational
	// purposes and to provide a watermark for which it is safe to prune earlier events from the sequencer data stores.
	// There is no requirement for every event to be individually acknowledged, and in fact callers are encouraged to
	// only periodically record acknowledgements (at an interval of minutes is expected to be more than sufficient for
	// pruning).
	Acknowledge(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error)
	// Newer version of acknowledgements.
	// To be active for protocol versions >= 4.
	// The argument here is an AcknowledgeRequest wrapped in SignedContent.
	// The signature is checked on the server side to avoid that malicious sequencers create fake
	// acknowledgements in multi-writer architectures where writers don't fully trust each other.
	//
	// Allows a member to acknowledge that they have read all events up to and including the provided timestamp,
	// and that they will never re-read these events again. This information is currently only used for informational
	// purposes and to provide a watermark for which it is safe to prune earlier events from the sequencer data stores.
	// There is no requirement for every event to be individually acknowledged, and in fact callers are encouraged to
	// only periodically record acknowledgements (at an interval of minutes is expected to be more than sufficient for
	// pruning).
	AcknowledgeSigned(context.Context, *v0.SignedContent) (*emptypb.Empty, error)
	// TODO(#11255) use a streaming response to avoid running into the grpc message size limit
	DownloadTopologyStateForInit(context.Context, *TopologyStateForInitRequest) (*TopologyStateForInitResponse, error)
	// contains filtered or unexported methods
}

SequencerServiceServer is the server API for SequencerService service. All implementations must embed UnimplementedSequencerServiceServer for forward compatibility

type SequencerService_SubscribeClient 

type SequencerService_SubscribeClient interface {
	Recv() (*SubscriptionResponse, error)
	grpc.ClientStream
}

type SequencerService_SubscribeServer 

type SequencerService_SubscribeServer interface {
	Send(*SubscriptionResponse) error
	grpc.ServerStream
}

type SequencerService_SubscribeUnauthenticatedClient 

type SequencerService_SubscribeUnauthenticatedClient interface {
	Recv() (*SubscriptionResponse, error)
	grpc.ClientStream
}

type SequencerService_SubscribeUnauthenticatedServer 

type SequencerService_SubscribeUnauthenticatedServer interface {
	Send(*SubscriptionResponse) error
	grpc.ServerStream
}

type SequencerService_SubscribeUnauthenticatedVersionedClient 

type SequencerService_SubscribeUnauthenticatedVersionedClient interface {
	Recv() (*VersionedSubscriptionResponse, error)
	grpc.ClientStream
}

type SequencerService_SubscribeUnauthenticatedVersionedServer 

type SequencerService_SubscribeUnauthenticatedVersionedServer interface {
	Send(*VersionedSubscriptionResponse) error
	grpc.ServerStream
}

type SequencerService_SubscribeVersionedClient 

type SequencerService_SubscribeVersionedClient interface {
	Recv() (*VersionedSubscriptionResponse, error)
	grpc.ClientStream
}

type SequencerService_SubscribeVersionedServer 

type SequencerService_SubscribeVersionedServer interface {
	Send(*VersionedSubscriptionResponse) error
	grpc.ServerStream
}

type SubscriptionRequest 

type SubscriptionRequest struct {
	Member string `protobuf:"bytes,1,opt,name=member,proto3" json:"member,omitempty"`
	// the counter indicates the next event to receive
	// e.g. requesting events from 0 will send the first event (index 0) when it exists.
	// a subscription request acts as an implicit ack for events with a lower counter value.
	Counter int64 `protobuf:"varint,2,opt,name=counter,proto3" json:"counter,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscriptionRequest) Descriptor deprecated 

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

Deprecated: Use SubscriptionRequest.ProtoReflect.Descriptor instead.

func (*SubscriptionRequest) GetCounter 

func (x *SubscriptionRequest) GetCounter() int64

func (*SubscriptionRequest) GetMember 

func (x *SubscriptionRequest) GetMember() string

func (*SubscriptionRequest) ProtoMessage 

func (*SubscriptionRequest) ProtoMessage()

func (*SubscriptionRequest) ProtoReflect 

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

func (*SubscriptionRequest) Reset 

func (x *SubscriptionRequest) Reset()

func (*SubscriptionRequest) String 

func (x *SubscriptionRequest) String() string

type SubscriptionResponse 

type SubscriptionResponse struct {
	SignedSequencedEvent *v0.SignedContent `protobuf:"bytes,1,opt,name=signed_sequenced_event,json=signedSequencedEvent,proto3" json:"signed_sequenced_event,omitempty"`
	// optional, canton trace context
	//
	// DO NOT RENAME this field, as the ApiRequestLogger uses reflection to read this field.
	//
	// We typically use a header to transfer this information however streamed items do
	// not have per item/message headers, so we instead in this instance set it in the body.
	TraceContext *v01.TraceContext `protobuf:"bytes,2,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"` // optional, canton trace context
	// contains filtered or unexported fields
}

func (*SubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use SubscriptionResponse.ProtoReflect.Descriptor instead.

func (*SubscriptionResponse) GetSignedSequencedEvent 

func (x *SubscriptionResponse) GetSignedSequencedEvent() *v0.SignedContent

func (*SubscriptionResponse) GetTraceContext 

func (x *SubscriptionResponse) GetTraceContext() *v01.TraceContext

func (*SubscriptionResponse) ProtoMessage 

func (*SubscriptionResponse) ProtoMessage()

func (*SubscriptionResponse) ProtoReflect 

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

func (*SubscriptionResponse) Reset 

func (x *SubscriptionResponse) Reset()

func (*SubscriptionResponse) String 

func (x *SubscriptionResponse) String() string

type TopologyStateForInitRequest 

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

func (*TopologyStateForInitRequest) Descriptor deprecated 

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

Deprecated: Use TopologyStateForInitRequest.ProtoReflect.Descriptor instead.

func (*TopologyStateForInitRequest) GetMember 

func (x *TopologyStateForInitRequest) GetMember() string

func (*TopologyStateForInitRequest) ProtoMessage 

func (*TopologyStateForInitRequest) ProtoMessage()

func (*TopologyStateForInitRequest) ProtoReflect 

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

func (*TopologyStateForInitRequest) Reset 

func (x *TopologyStateForInitRequest) Reset()

func (*TopologyStateForInitRequest) String 

func (x *TopologyStateForInitRequest) String() string

type TopologyStateForInitResponse 

type TopologyStateForInitResponse struct {
	TopologyTransactions *v0.TopologyTransactions `protobuf:"bytes,1,opt,name=topology_transactions,json=topologyTransactions,proto3" json:"topology_transactions,omitempty"`
	// contains filtered or unexported fields
}

func (*TopologyStateForInitResponse) Descriptor deprecated 

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

Deprecated: Use TopologyStateForInitResponse.ProtoReflect.Descriptor instead.

func (*TopologyStateForInitResponse) GetTopologyTransactions 

func (x *TopologyStateForInitResponse) GetTopologyTransactions() *v0.TopologyTransactions

func (*TopologyStateForInitResponse) ProtoMessage 

func (*TopologyStateForInitResponse) ProtoMessage()

func (*TopologyStateForInitResponse) ProtoReflect 

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

func (*TopologyStateForInitResponse) Reset 

func (x *TopologyStateForInitResponse) Reset()

func (*TopologyStateForInitResponse) String 

func (x *TopologyStateForInitResponse) String() string

type UnimplementedDomainServiceServer 

type UnimplementedDomainServiceServer struct {
}

UnimplementedDomainServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainServiceServer) GetServiceAgreement 

func (UnimplementedDomainServiceServer) GetServiceAgreement(context.Context, *GetServiceAgreementRequest) (*GetServiceAgreementResponse, error)

type UnimplementedDomainTimeServiceServer 

type UnimplementedDomainTimeServiceServer struct {
}

UnimplementedDomainTimeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDomainTimeServiceServer) AwaitTime 

func (UnimplementedDomainTimeServiceServer) AwaitTime(context.Context, *AwaitTimeRequest) (*emptypb.Empty, error)

func (UnimplementedDomainTimeServiceServer) FetchTime 

func (UnimplementedDomainTimeServiceServer) FetchTime(context.Context, *FetchTimeRequest) (*FetchTimeResponse, error)

type UnimplementedSequencerAuthenticationServiceServer 

type UnimplementedSequencerAuthenticationServiceServer struct {
}

UnimplementedSequencerAuthenticationServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerAuthenticationServiceServer) Authenticate 

func (UnimplementedSequencerAuthenticationServiceServer) Authenticate(context.Context, *Authentication_Request) (*Authentication_Response, error)

func (UnimplementedSequencerAuthenticationServiceServer) Challenge 

func (UnimplementedSequencerAuthenticationServiceServer) Challenge(context.Context, *Challenge_Request) (*Challenge_Response, error)

type UnimplementedSequencerConnectServiceServer 

type UnimplementedSequencerConnectServiceServer struct {
}

UnimplementedSequencerConnectServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerConnectServiceServer) GetDomainId 

func (UnimplementedSequencerConnectServiceServer) GetDomainId(context.Context, *SequencerConnect_GetDomainId_Request) (*SequencerConnect_GetDomainId_Response, error)

func (UnimplementedSequencerConnectServiceServer) GetDomainParameters 

func (UnimplementedSequencerConnectServiceServer) GetDomainParameters(context.Context, *SequencerConnect_GetDomainParameters_Request) (*SequencerConnect_GetDomainParameters_Response, error)

func (UnimplementedSequencerConnectServiceServer) GetServiceAgreement 

func (UnimplementedSequencerConnectServiceServer) GetServiceAgreement(context.Context, *GetServiceAgreementRequest) (*GetServiceAgreementResponse, error)

func (UnimplementedSequencerConnectServiceServer) Handshake 

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

func (UnimplementedSequencerConnectServiceServer) VerifyActive 

func (UnimplementedSequencerConnectServiceServer) VerifyActive(context.Context, *SequencerConnect_VerifyActive_Request) (*SequencerConnect_VerifyActive_Response, error)

type UnimplementedSequencerServiceServer 

type UnimplementedSequencerServiceServer struct {
}

UnimplementedSequencerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSequencerServiceServer) Acknowledge 

func (UnimplementedSequencerServiceServer) Acknowledge(context.Context, *AcknowledgeRequest) (*emptypb.Empty, error)

func (UnimplementedSequencerServiceServer) AcknowledgeSigned 

func (UnimplementedSequencerServiceServer) AcknowledgeSigned(context.Context, *v0.SignedContent) (*emptypb.Empty, error)

func (UnimplementedSequencerServiceServer) DownloadTopologyStateForInit 

func (UnimplementedSequencerServiceServer) DownloadTopologyStateForInit(context.Context, *TopologyStateForInitRequest) (*TopologyStateForInitResponse, error)

func (UnimplementedSequencerServiceServer) SendAsync 

func (UnimplementedSequencerServiceServer) SendAsync(context.Context, *v0.SubmissionRequest) (*SendAsyncResponse, error)

func (UnimplementedSequencerServiceServer) SendAsyncSigned 

func (UnimplementedSequencerServiceServer) SendAsyncSigned(context.Context, *v0.SignedContent) (*SendAsyncSignedResponse, error)

func (UnimplementedSequencerServiceServer) SendAsyncUnauthenticated 

func (UnimplementedSequencerServiceServer) SendAsyncUnauthenticated(context.Context, *v0.SubmissionRequest) (*SendAsyncResponse, error)

func (UnimplementedSequencerServiceServer) SendAsyncUnauthenticatedVersioned 

func (UnimplementedSequencerServiceServer) SendAsyncUnauthenticatedVersioned(context.Context, *SendAsyncUnauthenticatedVersionedRequest) (*SendAsyncResponse, error)

func (UnimplementedSequencerServiceServer) SendAsyncVersioned 

func (UnimplementedSequencerServiceServer) SendAsyncVersioned(context.Context, *SendAsyncVersionedRequest) (*SendAsyncSignedResponse, error)

func (UnimplementedSequencerServiceServer) Subscribe 

func (UnimplementedSequencerServiceServer) Subscribe(*SubscriptionRequest, SequencerService_SubscribeServer) error

func (UnimplementedSequencerServiceServer) SubscribeUnauthenticated 

func (UnimplementedSequencerServiceServer) SubscribeUnauthenticated(*SubscriptionRequest, SequencerService_SubscribeUnauthenticatedServer) error

func (UnimplementedSequencerServiceServer) SubscribeUnauthenticatedVersioned 

func (UnimplementedSequencerServiceServer) SubscribeUnauthenticatedVersioned(*SubscriptionRequest, SequencerService_SubscribeUnauthenticatedVersionedServer) error

func (UnimplementedSequencerServiceServer) SubscribeVersioned 

func (UnimplementedSequencerServiceServer) SubscribeVersioned(*SubscriptionRequest, SequencerService_SubscribeVersionedServer) error

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 UnsafeDomainTimeServiceServer 

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

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

type UnsafeSequencerAuthenticationServiceServer 

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

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

type UnsafeSequencerConnectServiceServer 

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

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

type UnsafeSequencerServiceServer 

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

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

type VersionedSubscriptionResponse 

type VersionedSubscriptionResponse struct {

	// Contains a versioned SignedContent of v0 or higher
	SignedSequencedEvent []byte `protobuf:"bytes,1,opt,name=signed_sequenced_event,json=signedSequencedEvent,proto3" json:"signed_sequenced_event,omitempty"`
	// optional, canton trace context
	//
	// DO NOT RENAME this field, as the ApiRequestLogger uses reflection to read this field.
	//
	// We typically use a header to transfer this information however streamed items do
	// not have per item/message headers, so we instead in this instance set it in the body.
	TraceContext *v01.TraceContext `protobuf:"bytes,2,opt,name=trace_context,json=traceContext,proto3" json:"trace_context,omitempty"` // optional, canton trace context
	// Traffic state for the subscribed member
	// Optional value which is set if the sequencer enforces traffic limits
	TrafficState *SequencedEventTrafficState `protobuf:"bytes,3,opt,name=traffic_state,json=trafficState,proto3" json:"traffic_state,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionedSubscriptionResponse) Descriptor deprecated 

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

Deprecated: Use VersionedSubscriptionResponse.ProtoReflect.Descriptor instead.

func (*VersionedSubscriptionResponse) GetSignedSequencedEvent 

func (x *VersionedSubscriptionResponse) GetSignedSequencedEvent() []byte

func (*VersionedSubscriptionResponse) GetTraceContext 

func (x *VersionedSubscriptionResponse) GetTraceContext() *v01.TraceContext

func (*VersionedSubscriptionResponse) GetTrafficState 

func (x *VersionedSubscriptionResponse) GetTrafficState() *SequencedEventTrafficState

func (*VersionedSubscriptionResponse) ProtoMessage 

func (*VersionedSubscriptionResponse) ProtoMessage()

func (*VersionedSubscriptionResponse) ProtoReflect 

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

func (*VersionedSubscriptionResponse) Reset 

func (x *VersionedSubscriptionResponse) Reset()

func (*VersionedSubscriptionResponse) String 

func (x *VersionedSubscriptionResponse) String() string

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.