protonotify

type NotificationRequest struct {
	TxStatusRequest *TxStatusRequest `protobuf:"bytes,1,opt,name=tx_status_request,json=txStatusRequest,proto3,oneof" json:"tx_status_request,omitempty"`
	// The timeout duration that applies to ALL the subscriptions in this request.
	// It is non-strict, i.e., it is possible to receive notifications for this request
	// after the timeout has passed.
	// If this field is not set or has a default value (zero), the default would be applied as
	// per the committer's configuration.
	Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// contains filtered or unexported fields
}

type NotificationResponse struct {
	TxStatusEvents []*TxStatusEvent `protobuf:"bytes,1,rep,name=tx_status_events,json=txStatusEvents,proto3" json:"tx_status_events,omitempty"` // List of transaction status events.
	TimeoutTxIds   []string         `protobuf:"bytes,2,rep,name=timeout_tx_ids,json=timeoutTxIds,proto3" json:"timeout_tx_ids,omitempty"`       // List of timeout events.
	// contains filtered or unexported fields
}

type NotifierClient interface {
	OpenNotificationStream(ctx context.Context, opts ...grpc.CallOption) (Notifier_OpenNotificationStreamClient, error)
}

type NotifierServer interface {
	OpenNotificationStream(Notifier_OpenNotificationStreamServer) error
	// contains filtered or unexported methods
}

type Notifier_OpenNotificationStreamClient interface {
	Send(*NotificationRequest) error
	Recv() (*NotificationResponse, error)
	grpc.ClientStream
}

type Notifier_OpenNotificationStreamServer interface {
	Send(*NotificationResponse) error
	Recv() (*NotificationRequest, error)
	grpc.ServerStream
}

type TxStatusEvent struct {
	TxId             string                         `protobuf:"bytes,1,opt,name=tx_id,json=txId,proto3" json:"tx_id,omitempty"`
	StatusWithHeight *protoblocktx.StatusWithHeight `protobuf:"bytes,2,opt,name=status_with_height,json=statusWithHeight,proto3" json:"status_with_height,omitempty"`
	// contains filtered or unexported fields
}

type TxStatusRequest struct {
	TxIds []string `protobuf:"bytes,1,rep,name=tx_ids,json=txIds,proto3" json:"tx_ids,omitempty"` // List of transaction IDS to be registered.
	// contains filtered or unexported fields
}

type UnimplementedNotifierServer struct {
}

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