services

package
v0.0.0-...-c4797cc Latest Latest
Warning

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

 Go to latest Published: Jan 27, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package services is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package services is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package services is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "UNKNOWN",
		1: "CREATED",
		2: "SUBMITTED",
		3: "SETTLED",
		4: "FAILED",
		5: "CONFIRMING",
	}
	Status_value = map[string]int32{
		"UNKNOWN":    0,
		"CREATED":    1,
		"SUBMITTED":  2,
		"SETTLED":    3,
		"FAILED":     4,
		"CONFIRMING": 5,
	}
)

Enum value maps for Status.

View Source 
var ExplorerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.ExplorerService",
	HandlerType: (*ExplorerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _ExplorerService_Query_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services/explorer-service.proto",
}

ExplorerService_ServiceDesc is the grpc.ServiceDesc for ExplorerService 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_services_explorer_service_proto protoreflect.FileDescriptor
View Source 
var File_services_relay_service_proto protoreflect.FileDescriptor
View Source 
var File_services_witness_service_proto protoreflect.FileDescriptor
View Source 
var RelayService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.RelayService",
	HandlerType: (*RelayServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Submit",
			Handler:    _RelayService_Submit_Handler,
		},
		{
			MethodName: "Reset",
			Handler:    _RelayService_Reset_Handler,
		},
		{
			MethodName: "Check",
			Handler:    _RelayService_Check_Handler,
		},
		{
			MethodName: "Lookup",
			Handler:    _RelayService_Lookup_Handler,
		},
		{
			MethodName: "StaleHeights",
			Handler:    _RelayService_StaleHeights_Handler,
		},
		{
			MethodName: "List",
			Handler:    _RelayService_List_Handler,
		},
		{
			MethodName: "SubmitNewTX",
			Handler:    _RelayService_SubmitNewTX_Handler,
		},
		{
			MethodName: "ListNewTX",
			Handler:    _RelayService_ListNewTX_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services/relay-service.proto",
}

RelayService_ServiceDesc is the grpc.ServiceDesc for RelayService 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 WitnessService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "services.WitnessService",
	HandlerType: (*WitnessServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Query",
			Handler:    _WitnessService_Query_Handler,
		},
		{
			MethodName: "FetchByHeights",
			Handler:    _WitnessService_FetchByHeights_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "services/witness-service.proto",
}

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

Functions

func RegisterExplorerServiceHandler 

func RegisterExplorerServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterExplorerServiceHandler registers the http handlers for service ExplorerService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterExplorerServiceHandlerClient 

func RegisterExplorerServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ExplorerServiceClient) error

RegisterExplorerServiceHandlerClient registers the http handlers for service ExplorerService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ExplorerServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ExplorerServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ExplorerServiceClient" to call the correct interceptors.

func RegisterExplorerServiceHandlerFromEndpoint 

func RegisterExplorerServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterExplorerServiceHandlerFromEndpoint is same as RegisterExplorerServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterExplorerServiceHandlerServer 

func RegisterExplorerServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ExplorerServiceServer) error

RegisterExplorerServiceHandlerServer registers the http handlers for service ExplorerService to "mux". UnaryRPC :call ExplorerServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterExplorerServiceHandlerFromEndpoint instead.

func RegisterExplorerServiceServer 

func RegisterExplorerServiceServer(s grpc.ServiceRegistrar, srv ExplorerServiceServer)

func RegisterRelayServiceHandler 

func RegisterRelayServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRelayServiceHandler registers the http handlers for service RelayService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRelayServiceHandlerClient 

func RegisterRelayServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RelayServiceClient) error

RegisterRelayServiceHandlerClient registers the http handlers for service RelayService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RelayServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RelayServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RelayServiceClient" to call the correct interceptors.

func RegisterRelayServiceHandlerFromEndpoint 

func RegisterRelayServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRelayServiceHandlerFromEndpoint is same as RegisterRelayServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRelayServiceHandlerServer 

func RegisterRelayServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RelayServiceServer) error

RegisterRelayServiceHandlerServer registers the http handlers for service RelayService to "mux". UnaryRPC :call RelayServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterRelayServiceHandlerFromEndpoint instead.

func RegisterRelayServiceServer 

func RegisterRelayServiceServer(s grpc.ServiceRegistrar, srv RelayServiceServer)

func RegisterWitnessServiceHandler 

func RegisterWitnessServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterWitnessServiceHandler registers the http handlers for service WitnessService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterWitnessServiceHandlerClient 

func RegisterWitnessServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client WitnessServiceClient) error

RegisterWitnessServiceHandlerClient registers the http handlers for service WitnessService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "WitnessServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "WitnessServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "WitnessServiceClient" to call the correct interceptors.

func RegisterWitnessServiceHandlerFromEndpoint 

func RegisterWitnessServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterWitnessServiceHandlerFromEndpoint is same as RegisterWitnessServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterWitnessServiceHandlerServer 

func RegisterWitnessServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server WitnessServiceServer) error

RegisterWitnessServiceHandlerServer registers the http handlers for service WitnessService to "mux". UnaryRPC :call WitnessServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterWitnessServiceHandlerFromEndpoint instead.

func RegisterWitnessServiceServer 

func RegisterWitnessServiceServer(s grpc.ServiceRegistrar, srv WitnessServiceServer)

Types

type CheckRequest 

type CheckRequest struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckRequest) Descriptor deprecated 

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

Deprecated: Use CheckRequest.ProtoReflect.Descriptor instead.

func (*CheckRequest) GetId 

func (x *CheckRequest) GetId() []byte

func (*CheckRequest) ProtoMessage 

func (*CheckRequest) ProtoMessage()

func (*CheckRequest) ProtoReflect 

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

func (*CheckRequest) Reset 

func (x *CheckRequest) Reset()

func (*CheckRequest) String 

func (x *CheckRequest) String() string

type CheckResponse 

type CheckResponse struct {
	Key       []byte   `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Witnesses [][]byte `protobuf:"bytes,2,rep,name=witnesses,proto3" json:"witnesses,omitempty"`
	TxHash    []byte   `protobuf:"bytes,3,opt,name=txHash,proto3" json:"txHash,omitempty"`
	Status    Status   `protobuf:"varint,4,opt,name=status,proto3,enum=services.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckResponse) Descriptor deprecated 

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

Deprecated: Use CheckResponse.ProtoReflect.Descriptor instead.

func (*CheckResponse) GetKey 

func (x *CheckResponse) GetKey() []byte

func (*CheckResponse) GetStatus 

func (x *CheckResponse) GetStatus() Status

func (*CheckResponse) GetTxHash 

func (x *CheckResponse) GetTxHash() []byte

func (*CheckResponse) GetWitnesses 

func (x *CheckResponse) GetWitnesses() [][]byte

func (*CheckResponse) ProtoMessage 

func (*CheckResponse) ProtoMessage()

func (*CheckResponse) ProtoReflect 

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

func (*CheckResponse) Reset 

func (x *CheckResponse) Reset()

func (*CheckResponse) String 

func (x *CheckResponse) String() string

type ExplorerQueryRequest 

type ExplorerQueryRequest struct {
	First     int32    `protobuf:"varint,1,opt,name=first,proto3" json:"first,omitempty"`
	Skip      int32    `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"`
	Token     []byte   `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Sender    []byte   `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"`
	Recipient []byte   `protobuf:"bytes,5,opt,name=recipient,proto3" json:"recipient,omitempty"`
	Status    Status   `protobuf:"varint,6,opt,name=status,proto3,enum=services.Status" json:"status,omitempty"`
	Cashiers  [][]byte `protobuf:"bytes,7,rep,name=cashiers,proto3" json:"cashiers,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplorerQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExplorerQueryRequest.ProtoReflect.Descriptor instead.

func (*ExplorerQueryRequest) GetCashiers 

func (x *ExplorerQueryRequest) GetCashiers() [][]byte

func (*ExplorerQueryRequest) GetFirst 

func (x *ExplorerQueryRequest) GetFirst() int32

func (*ExplorerQueryRequest) GetRecipient 

func (x *ExplorerQueryRequest) GetRecipient() []byte

func (*ExplorerQueryRequest) GetSender 

func (x *ExplorerQueryRequest) GetSender() []byte

func (*ExplorerQueryRequest) GetSkip 

func (x *ExplorerQueryRequest) GetSkip() int32

func (*ExplorerQueryRequest) GetStatus 

func (x *ExplorerQueryRequest) GetStatus() Status

func (*ExplorerQueryRequest) GetToken 

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

func (*ExplorerQueryRequest) ProtoMessage 

func (*ExplorerQueryRequest) ProtoMessage()

func (*ExplorerQueryRequest) ProtoReflect 

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

func (*ExplorerQueryRequest) Reset 

func (x *ExplorerQueryRequest) Reset()

func (*ExplorerQueryRequest) String 

func (x *ExplorerQueryRequest) String() string

type ExplorerQueryResponse 

type ExplorerQueryResponse struct {
	Transfers []*types.Transfer `protobuf:"bytes,1,rep,name=transfers,proto3" json:"transfers,omitempty"`
	Statuses  []*CheckResponse  `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Count     uint32            `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplorerQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExplorerQueryResponse.ProtoReflect.Descriptor instead.

func (*ExplorerQueryResponse) GetCount 

func (x *ExplorerQueryResponse) GetCount() uint32

func (*ExplorerQueryResponse) GetStatuses 

func (x *ExplorerQueryResponse) GetStatuses() []*CheckResponse

func (*ExplorerQueryResponse) GetTransfers 

func (x *ExplorerQueryResponse) GetTransfers() []*types.Transfer

func (*ExplorerQueryResponse) ProtoMessage 

func (*ExplorerQueryResponse) ProtoMessage()

func (*ExplorerQueryResponse) ProtoReflect 

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

func (*ExplorerQueryResponse) Reset 

func (x *ExplorerQueryResponse) Reset()

func (*ExplorerQueryResponse) String 

func (x *ExplorerQueryResponse) String() string

type ExplorerServiceClient 

type ExplorerServiceClient interface {
	Query(ctx context.Context, in *ExplorerQueryRequest, opts ...grpc.CallOption) (*ExplorerQueryResponse, error)
}

ExplorerServiceClient is the client API for ExplorerService 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 NewExplorerServiceClient 

func NewExplorerServiceClient(cc grpc.ClientConnInterface) ExplorerServiceClient

type ExplorerServiceServer 

type ExplorerServiceServer interface {
	Query(context.Context, *ExplorerQueryRequest) (*ExplorerQueryResponse, error)
	// contains filtered or unexported methods
}

ExplorerServiceServer is the server API for ExplorerService service. All implementations must embed UnimplementedExplorerServiceServer for forward compatibility

type FetchRequest 

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

func (*FetchRequest) Descriptor deprecated 

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

Deprecated: Use FetchRequest.ProtoReflect.Descriptor instead.

func (*FetchRequest) GetHeights 

func (x *FetchRequest) GetHeights() string

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) ProtoReflect 

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

func (*FetchRequest) Reset 

func (x *FetchRequest) Reset()

func (*FetchRequest) String 

func (x *FetchRequest) String() string

type ListNewTXRequest 

type ListNewTXRequest struct {
	Count uint32 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNewTXRequest) Descriptor deprecated 

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

Deprecated: Use ListNewTXRequest.ProtoReflect.Descriptor instead.

func (*ListNewTXRequest) GetCount 

func (x *ListNewTXRequest) GetCount() uint32

func (*ListNewTXRequest) ProtoMessage 

func (*ListNewTXRequest) ProtoMessage()

func (*ListNewTXRequest) ProtoReflect 

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

func (*ListNewTXRequest) Reset 

func (x *ListNewTXRequest) Reset()

func (*ListNewTXRequest) String 

func (x *ListNewTXRequest) String() string

type ListNewTXResponse 

type ListNewTXResponse struct {
	Txs []*SubmitNewTXRequest `protobuf:"bytes,1,rep,name=txs,proto3" json:"txs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListNewTXResponse) Descriptor deprecated 

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

Deprecated: Use ListNewTXResponse.ProtoReflect.Descriptor instead.

func (*ListNewTXResponse) GetTxs 

func (x *ListNewTXResponse) GetTxs() []*SubmitNewTXRequest

func (*ListNewTXResponse) ProtoMessage 

func (*ListNewTXResponse) ProtoMessage()

func (*ListNewTXResponse) ProtoReflect 

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

func (*ListNewTXResponse) Reset 

func (x *ListNewTXResponse) Reset()

func (*ListNewTXResponse) String 

func (x *ListNewTXResponse) String() string

type ListRequest 

type ListRequest struct {
	First     int32  `protobuf:"varint,1,opt,name=first,proto3" json:"first,omitempty"`
	Skip      int32  `protobuf:"varint,2,opt,name=skip,proto3" json:"skip,omitempty"`
	Token     []byte `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	Sender    []byte `protobuf:"bytes,4,opt,name=sender,proto3" json:"sender,omitempty"`
	Recipient []byte `protobuf:"bytes,5,opt,name=recipient,proto3" json:"recipient,omitempty"`
	Status    Status `protobuf:"varint,6,opt,name=status,proto3,enum=services.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetFirst 

func (x *ListRequest) GetFirst() int32

func (*ListRequest) GetRecipient 

func (x *ListRequest) GetRecipient() []byte

func (*ListRequest) GetSender 

func (x *ListRequest) GetSender() []byte

func (*ListRequest) GetSkip 

func (x *ListRequest) GetSkip() int32

func (*ListRequest) GetStatus 

func (x *ListRequest) GetStatus() Status

func (*ListRequest) GetToken 

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

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Transfers []*types.Transfer `protobuf:"bytes,1,rep,name=transfers,proto3" json:"transfers,omitempty"`
	Statuses  []*CheckResponse  `protobuf:"bytes,2,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Count     uint32            `protobuf:"varint,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetCount 

func (x *ListResponse) GetCount() uint32

func (*ListResponse) GetStatuses 

func (x *ListResponse) GetStatuses() []*CheckResponse

func (*ListResponse) GetTransfers 

func (x *ListResponse) GetTransfers() []*types.Transfer

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type LookupRequest 

type LookupRequest struct {
	SourceTxHash []byte `protobuf:"bytes,1,opt,name=sourceTxHash,proto3" json:"sourceTxHash,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupRequest) Descriptor deprecated 

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

Deprecated: Use LookupRequest.ProtoReflect.Descriptor instead.

func (*LookupRequest) GetSourceTxHash 

func (x *LookupRequest) GetSourceTxHash() []byte

func (*LookupRequest) ProtoMessage 

func (*LookupRequest) ProtoMessage()

func (*LookupRequest) ProtoReflect 

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

func (*LookupRequest) Reset 

func (x *LookupRequest) Reset()

func (*LookupRequest) String 

func (x *LookupRequest) String() string

type LookupResponse 

type LookupResponse struct {
	Statuses []*CheckResponse `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupResponse) Descriptor deprecated 

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

Deprecated: Use LookupResponse.ProtoReflect.Descriptor instead.

func (*LookupResponse) GetStatuses 

func (x *LookupResponse) GetStatuses() []*CheckResponse

func (*LookupResponse) ProtoMessage 

func (*LookupResponse) ProtoMessage()

func (*LookupResponse) ProtoReflect 

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

func (*LookupResponse) Reset 

func (x *LookupResponse) Reset()

func (*LookupResponse) String 

func (x *LookupResponse) String() string

type QueryRequest 

type QueryRequest struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetId 

func (x *QueryRequest) GetId() []byte

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Transfer *types.Transfer `protobuf:"bytes,1,opt,name=transfer,proto3" json:"transfer,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetTransfer 

func (x *QueryResponse) GetTransfer() *types.Transfer

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type RelayServiceClient 

type RelayServiceClient interface {
	Submit(ctx context.Context, in *types.Witness, opts ...grpc.CallOption) (*WitnessSubmissionResponse, error)
	Reset(ctx context.Context, in *ResetTransferRequest, opts ...grpc.CallOption) (*ResetTransferResponse, error)
	Check(ctx context.Context, in *CheckRequest, opts ...grpc.CallOption) (*CheckResponse, error)
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
	StaleHeights(ctx context.Context, in *StaleHeightsRequest, opts ...grpc.CallOption) (*StaleHeightsResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	SubmitNewTX(ctx context.Context, in *SubmitNewTXRequest, opts ...grpc.CallOption) (*SubmitNewTXResponse, error)
	ListNewTX(ctx context.Context, in *ListNewTXRequest, opts ...grpc.CallOption) (*ListNewTXResponse, error)
}

RelayServiceClient is the client API for RelayService 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 NewRelayServiceClient 

func NewRelayServiceClient(cc grpc.ClientConnInterface) RelayServiceClient

type RelayServiceServer 

type RelayServiceServer interface {
	Submit(context.Context, *types.Witness) (*WitnessSubmissionResponse, error)
	Reset(context.Context, *ResetTransferRequest) (*ResetTransferResponse, error)
	Check(context.Context, *CheckRequest) (*CheckResponse, error)
	Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
	StaleHeights(context.Context, *StaleHeightsRequest) (*StaleHeightsResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	SubmitNewTX(context.Context, *SubmitNewTXRequest) (*SubmitNewTXResponse, error)
	ListNewTX(context.Context, *ListNewTXRequest) (*ListNewTXResponse, error)
	// contains filtered or unexported methods
}

RelayServiceServer is the server API for RelayService service. All implementations must embed UnimplementedRelayServiceServer for forward compatibility

type ResetTransferRequest 

type ResetTransferRequest struct {
	Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetTransferRequest) Descriptor deprecated 

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

Deprecated: Use ResetTransferRequest.ProtoReflect.Descriptor instead.

func (*ResetTransferRequest) GetId 

func (x *ResetTransferRequest) GetId() []byte

func (*ResetTransferRequest) ProtoMessage 

func (*ResetTransferRequest) ProtoMessage()

func (*ResetTransferRequest) ProtoReflect 

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

func (*ResetTransferRequest) Reset 

func (x *ResetTransferRequest) Reset()

func (*ResetTransferRequest) String 

func (x *ResetTransferRequest) String() string

type ResetTransferResponse 

type ResetTransferResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetTransferResponse) Descriptor deprecated 

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

Deprecated: Use ResetTransferResponse.ProtoReflect.Descriptor instead.

func (*ResetTransferResponse) GetSuccess 

func (x *ResetTransferResponse) GetSuccess() bool

func (*ResetTransferResponse) ProtoMessage 

func (*ResetTransferResponse) ProtoMessage()

func (*ResetTransferResponse) ProtoReflect 

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

func (*ResetTransferResponse) Reset 

func (x *ResetTransferResponse) Reset()

func (*ResetTransferResponse) String 

func (x *ResetTransferResponse) String() string

type StaleHeightsRequest 

type StaleHeightsRequest struct {
	Cashier []byte `protobuf:"bytes,1,opt,name=cashier,proto3" json:"cashier,omitempty"`
	// contains filtered or unexported fields
}

func (*StaleHeightsRequest) Descriptor deprecated 

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

Deprecated: Use StaleHeightsRequest.ProtoReflect.Descriptor instead.

func (*StaleHeightsRequest) GetCashier 

func (x *StaleHeightsRequest) GetCashier() []byte

func (*StaleHeightsRequest) ProtoMessage 

func (*StaleHeightsRequest) ProtoMessage()

func (*StaleHeightsRequest) ProtoReflect 

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

func (*StaleHeightsRequest) Reset 

func (x *StaleHeightsRequest) Reset()

func (*StaleHeightsRequest) String 

func (x *StaleHeightsRequest) String() string

type StaleHeightsResponse 

type StaleHeightsResponse struct {
	Heights []uint64 `protobuf:"varint,1,rep,packed,name=heights,proto3" json:"heights,omitempty"`
	// contains filtered or unexported fields
}

func (*StaleHeightsResponse) Descriptor deprecated 

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

Deprecated: Use StaleHeightsResponse.ProtoReflect.Descriptor instead.

func (*StaleHeightsResponse) GetHeights 

func (x *StaleHeightsResponse) GetHeights() []uint64

func (*StaleHeightsResponse) ProtoMessage 

func (*StaleHeightsResponse) ProtoMessage()

func (*StaleHeightsResponse) ProtoReflect 

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

func (*StaleHeightsResponse) Reset 

func (x *StaleHeightsResponse) Reset()

func (*StaleHeightsResponse) String 

func (x *StaleHeightsResponse) String() string

type Status 

type Status int32
const (
	Status_UNKNOWN    Status = 0
	Status_CREATED    Status = 1
	Status_SUBMITTED  Status = 2
	Status_SETTLED    Status = 3
	Status_FAILED     Status = 4
	Status_CONFIRMING Status = 5
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type SubmitNewTXRequest 

type SubmitNewTXRequest struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	TxHash []byte `protobuf:"bytes,2,opt,name=txHash,proto3" json:"txHash,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitNewTXRequest) Descriptor deprecated 

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

Deprecated: Use SubmitNewTXRequest.ProtoReflect.Descriptor instead.

func (*SubmitNewTXRequest) GetHeight 

func (x *SubmitNewTXRequest) GetHeight() uint64

func (*SubmitNewTXRequest) GetTxHash 

func (x *SubmitNewTXRequest) GetTxHash() []byte

func (*SubmitNewTXRequest) ProtoMessage 

func (*SubmitNewTXRequest) ProtoMessage()

func (*SubmitNewTXRequest) ProtoReflect 

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

func (*SubmitNewTXRequest) Reset 

func (x *SubmitNewTXRequest) Reset()

func (*SubmitNewTXRequest) String 

func (x *SubmitNewTXRequest) String() string

type SubmitNewTXResponse 

type SubmitNewTXResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitNewTXResponse) Descriptor deprecated 

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

Deprecated: Use SubmitNewTXResponse.ProtoReflect.Descriptor instead.

func (*SubmitNewTXResponse) GetSuccess 

func (x *SubmitNewTXResponse) GetSuccess() bool

func (*SubmitNewTXResponse) ProtoMessage 

func (*SubmitNewTXResponse) ProtoMessage()

func (*SubmitNewTXResponse) ProtoReflect 

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

func (*SubmitNewTXResponse) Reset 

func (x *SubmitNewTXResponse) Reset()

func (*SubmitNewTXResponse) String 

func (x *SubmitNewTXResponse) String() string

type UnimplementedExplorerServiceServer 

type UnimplementedExplorerServiceServer struct {
}

UnimplementedExplorerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedExplorerServiceServer) Query 

func (UnimplementedExplorerServiceServer) Query(context.Context, *ExplorerQueryRequest) (*ExplorerQueryResponse, error)

type UnimplementedRelayServiceServer 

type UnimplementedRelayServiceServer struct {
}

UnimplementedRelayServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRelayServiceServer) Check 

func (UnimplementedRelayServiceServer) Check(context.Context, *CheckRequest) (*CheckResponse, error)

func (UnimplementedRelayServiceServer) List 

func (UnimplementedRelayServiceServer) List(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedRelayServiceServer) ListNewTX 

func (UnimplementedRelayServiceServer) ListNewTX(context.Context, *ListNewTXRequest) (*ListNewTXResponse, error)

func (UnimplementedRelayServiceServer) Lookup 

func (UnimplementedRelayServiceServer) Lookup(context.Context, *LookupRequest) (*LookupResponse, error)

func (UnimplementedRelayServiceServer) Reset 

func (UnimplementedRelayServiceServer) Reset(context.Context, *ResetTransferRequest) (*ResetTransferResponse, error)

func (UnimplementedRelayServiceServer) StaleHeights 

func (UnimplementedRelayServiceServer) StaleHeights(context.Context, *StaleHeightsRequest) (*StaleHeightsResponse, error)

func (UnimplementedRelayServiceServer) Submit 

func (UnimplementedRelayServiceServer) Submit(context.Context, *types.Witness) (*WitnessSubmissionResponse, error)

func (UnimplementedRelayServiceServer) SubmitNewTX 

func (UnimplementedRelayServiceServer) SubmitNewTX(context.Context, *SubmitNewTXRequest) (*SubmitNewTXResponse, error)

type UnimplementedWitnessServiceServer 

type UnimplementedWitnessServiceServer struct {
}

UnimplementedWitnessServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWitnessServiceServer) FetchByHeights 

func (UnimplementedWitnessServiceServer) FetchByHeights(context.Context, *FetchRequest) (*emptypb.Empty, error)

func (UnimplementedWitnessServiceServer) Query 

func (UnimplementedWitnessServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

type UnsafeExplorerServiceServer 

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

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

type UnsafeRelayServiceServer 

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

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

type UnsafeWitnessServiceServer 

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

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

type WitnessServiceClient 

type WitnessServiceClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	FetchByHeights(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

WitnessServiceClient is the client API for WitnessService 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 NewWitnessServiceClient 

func NewWitnessServiceClient(cc grpc.ClientConnInterface) WitnessServiceClient

type WitnessServiceServer 

type WitnessServiceServer interface {
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	FetchByHeights(context.Context, *FetchRequest) (*emptypb.Empty, error)
	// contains filtered or unexported methods
}

WitnessServiceServer is the server API for WitnessService service. All implementations must embed UnimplementedWitnessServiceServer for forward compatibility

type WitnessSubmissionResponse 

type WitnessSubmissionResponse struct {
	Id      []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Success bool   `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*WitnessSubmissionResponse) Descriptor deprecated 

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

Deprecated: Use WitnessSubmissionResponse.ProtoReflect.Descriptor instead.

func (*WitnessSubmissionResponse) GetId 

func (x *WitnessSubmissionResponse) GetId() []byte

func (*WitnessSubmissionResponse) GetSuccess 

func (x *WitnessSubmissionResponse) GetSuccess() bool

func (*WitnessSubmissionResponse) ProtoMessage 

func (*WitnessSubmissionResponse) ProtoMessage()

func (*WitnessSubmissionResponse) ProtoReflect 

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

func (*WitnessSubmissionResponse) Reset 

func (x *WitnessSubmissionResponse) Reset()

func (*WitnessSubmissionResponse) String 

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