shared

package
v0.0.11 Latest Latest
Warning

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

 Go to latest Published: Nov 27, 2024 License: MIT Imports: 22 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

View Source 
const (
	Msg_UpdateParams_FullMethodName = "/poktroll.shared.Msg/UpdateParams"
	Msg_UpdateParam_FullMethodName  = "/poktroll.shared.Msg/UpdateParam"
)
View Source 
const (
	Query_Params_FullMethodName = "/poktroll.shared.Query/Params"
)

Variables

View Source 
var (
	RPCType_name = map[int32]string{
		0: "UNKNOWN_RPC",
		1: "GRPC",
		2: "WEBSOCKET",
		3: "JSON_RPC",
		4: "REST",
	}
	RPCType_value = map[string]int32{
		"UNKNOWN_RPC": 0,
		"GRPC":        1,
		"WEBSOCKET":   2,
		"JSON_RPC":    3,
		"REST":        4,
	}
)

Enum value maps for RPCType.

View Source 
var (
	ConfigOptions_name = map[int32]string{
		0: "UNKNOWN_CONFIG",
		1: "TIMEOUT",
	}
	ConfigOptions_value = map[string]int32{
		"UNKNOWN_CONFIG": 0,
		"TIMEOUT":        1,
	}
)

Enum value maps for ConfigOptions.

View Source 
var File_poktroll_shared_genesis_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_shared_params_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_shared_query_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_shared_service_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_shared_supplier_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_shared_tx_proto protoreflect.FileDescriptor
View Source 
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "poktroll.shared.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "UpdateParams",
			Handler:    _Msg_UpdateParams_Handler,
		},
		{
			MethodName: "UpdateParam",
			Handler:    _Msg_UpdateParam_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "poktroll/shared/tx.proto",
}

Msg_ServiceDesc is the grpc.ServiceDesc for Msg 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 Query_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "poktroll.shared.Query",
	HandlerType: (*QueryServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Params",
			Handler:    _Query_Params_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "poktroll/shared/query.proto",
}

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

Functions

func RegisterMsgServer added in v0.0.3 

func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)

func RegisterQueryServer added in v0.0.3 

func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)

Types

type ApplicationServiceConfig 

type ApplicationServiceConfig struct {
	ServiceId string `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` // The Service ID for which the application is configured
	// contains filtered or unexported fields
}

ApplicationServiceConfig holds the service configuration the application stakes for

func (*ApplicationServiceConfig) Descriptor deprecated 

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

Deprecated: Use ApplicationServiceConfig.ProtoReflect.Descriptor instead.

func (*ApplicationServiceConfig) GetServiceId added in v0.0.8 

func (x *ApplicationServiceConfig) GetServiceId() string

func (*ApplicationServiceConfig) ProtoMessage 

func (*ApplicationServiceConfig) ProtoMessage()

func (*ApplicationServiceConfig) ProtoReflect 

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

func (*ApplicationServiceConfig) Reset 

func (x *ApplicationServiceConfig) Reset()

func (*ApplicationServiceConfig) String 

func (x *ApplicationServiceConfig) String() string

type ConfigOption 

type ConfigOption struct {
	Key   ConfigOptions `protobuf:"varint,1,opt,name=key,proto3,enum=poktroll.shared.ConfigOptions" json:"key,omitempty"` // Config option key
	Value string        `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`                                 // Config option value
	// contains filtered or unexported fields
}

Key-value wrapper for config options, as proto maps can't be keyed by enums

func (*ConfigOption) Descriptor deprecated 

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

Deprecated: Use ConfigOption.ProtoReflect.Descriptor instead.

func (*ConfigOption) GetKey 

func (x *ConfigOption) GetKey() ConfigOptions

func (*ConfigOption) GetValue 

func (x *ConfigOption) GetValue() string

func (*ConfigOption) ProtoMessage 

func (*ConfigOption) ProtoMessage()

func (*ConfigOption) ProtoReflect 

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

func (*ConfigOption) Reset 

func (x *ConfigOption) Reset()

func (*ConfigOption) String 

func (x *ConfigOption) String() string

type ConfigOptions 

type ConfigOptions int32

Enum to define configuration options TODO_RESEARCH: Should these be configs, SLAs or something else? There will be more discussion once we get closer to implementing on-chain QoS. 

const (
	ConfigOptions_UNKNOWN_CONFIG ConfigOptions = 0 // Undefined config option
	ConfigOptions_TIMEOUT        ConfigOptions = 1 // Timeout setting
)

func (ConfigOptions) Descriptor 

func (ConfigOptions) Descriptor() protoreflect.EnumDescriptor

func (ConfigOptions) Enum 

func (x ConfigOptions) Enum() *ConfigOptions

func (ConfigOptions) EnumDescriptor deprecated 

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

Deprecated: Use ConfigOptions.Descriptor instead.

func (ConfigOptions) Number 

func (x ConfigOptions) Number() protoreflect.EnumNumber

func (ConfigOptions) String 

func (x ConfigOptions) String() string

func (ConfigOptions) Type 

func (ConfigOptions) Type() protoreflect.EnumType

type GenesisState added in v0.0.3 

type GenesisState struct {

	// params defines all the parameters of the module.
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

GenesisState defines the shared module's genesis state.

func (*GenesisState) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.

func (*GenesisState) GetParams added in v0.0.3 

func (x *GenesisState) GetParams() *Params

func (*GenesisState) ProtoMessage added in v0.0.3 

func (*GenesisState) ProtoMessage()

func (*GenesisState) ProtoReflect added in v0.0.3 

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

func (*GenesisState) Reset added in v0.0.3 

func (x *GenesisState) Reset()

func (*GenesisState) String added in v0.0.3 

func (x *GenesisState) String() string

type MsgClient added in v0.0.3 

type MsgClient interface {
	// UpdateParams defines a (governance) operation for updating the module
	// parameters. The authority defaults to the x/gov module account.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	UpdateParam(ctx context.Context, in *MsgUpdateParam, opts ...grpc.CallOption) (*MsgUpdateParamResponse, error)
}

MsgClient is the client API for Msg 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.

Msg defines the Msg service.

func NewMsgClient added in v0.0.3 

func NewMsgClient(cc grpc.ClientConnInterface) MsgClient

type MsgServer added in v0.0.3 

type MsgServer interface {
	// UpdateParams defines a (governance) operation for updating the module
	// parameters. The authority defaults to the x/gov module account.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	UpdateParam(context.Context, *MsgUpdateParam) (*MsgUpdateParamResponse, error)
	// contains filtered or unexported methods
}

MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility

Msg defines the Msg service.

type MsgUpdateParam added in v0.0.3 

type MsgUpdateParam struct {

	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to AsType:
	//
	//	*MsgUpdateParam_AsString
	//	*MsgUpdateParam_AsUint64
	//	*MsgUpdateParam_AsBytes
	AsType isMsgUpdateParam_AsType `protobuf_oneof:"as_type"`
	// contains filtered or unexported fields
}

MsgUpdateParam is the Msg/UpdateParam request type to update a single param.

func (*MsgUpdateParam) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use MsgUpdateParam.ProtoReflect.Descriptor instead.

func (*MsgUpdateParam) GetAsBytes added in v0.0.3 

func (x *MsgUpdateParam) GetAsBytes() []byte

func (*MsgUpdateParam) GetAsString added in v0.0.3 

func (x *MsgUpdateParam) GetAsString() string

func (*MsgUpdateParam) GetAsType added in v0.0.3 

func (x *MsgUpdateParam) GetAsType() isMsgUpdateParam_AsType

func (*MsgUpdateParam) GetAsUint64 added in v0.0.10 

func (x *MsgUpdateParam) GetAsUint64() uint64

func (*MsgUpdateParam) GetAuthority added in v0.0.3 

func (x *MsgUpdateParam) GetAuthority() string

func (*MsgUpdateParam) GetName added in v0.0.3 

func (x *MsgUpdateParam) GetName() string

func (*MsgUpdateParam) ProtoMessage added in v0.0.3 

func (*MsgUpdateParam) ProtoMessage()

func (*MsgUpdateParam) ProtoReflect added in v0.0.3 

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

func (*MsgUpdateParam) Reset added in v0.0.3 

func (x *MsgUpdateParam) Reset()

func (*MsgUpdateParam) String added in v0.0.3 

func (x *MsgUpdateParam) String() string

type MsgUpdateParamResponse added in v0.0.3 

type MsgUpdateParamResponse struct {
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateParamResponse defines the response structure for executing a MsgUpdateParam message after a single param update.

func (*MsgUpdateParamResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use MsgUpdateParamResponse.ProtoReflect.Descriptor instead.

func (*MsgUpdateParamResponse) GetParams added in v0.0.3 

func (x *MsgUpdateParamResponse) GetParams() *Params

func (*MsgUpdateParamResponse) ProtoMessage added in v0.0.3 

func (*MsgUpdateParamResponse) ProtoMessage()

func (*MsgUpdateParamResponse) ProtoReflect added in v0.0.3 

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

func (*MsgUpdateParamResponse) Reset added in v0.0.3 

func (x *MsgUpdateParamResponse) Reset()

func (*MsgUpdateParamResponse) String added in v0.0.3 

func (x *MsgUpdateParamResponse) String() string

type MsgUpdateParam_AsBytes added in v0.0.3 

type MsgUpdateParam_AsBytes struct {
	AsBytes []byte `protobuf:"bytes,7,opt,name=as_bytes,json=asBytes,proto3,oneof"`
}

type MsgUpdateParam_AsString added in v0.0.3 

type MsgUpdateParam_AsString struct {
	AsString string `protobuf:"bytes,3,opt,name=as_string,json=asString,proto3,oneof"`
}

type MsgUpdateParam_AsUint64 added in v0.0.10 

type MsgUpdateParam_AsUint64 struct {
	AsUint64 uint64 `protobuf:"varint,6,opt,name=as_uint64,json=asUint64,proto3,oneof"`
}

type MsgUpdateParams added in v0.0.3 

type MsgUpdateParams struct {

	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// NOTE: All parameters must be supplied.
	Params *Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

MsgUpdateParams is the Msg/UpdateParams request type.

func (*MsgUpdateParams) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use MsgUpdateParams.ProtoReflect.Descriptor instead.

func (*MsgUpdateParams) GetAuthority added in v0.0.3 

func (x *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams added in v0.0.3 

func (x *MsgUpdateParams) GetParams() *Params

func (*MsgUpdateParams) ProtoMessage added in v0.0.3 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) ProtoReflect added in v0.0.3 

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

func (*MsgUpdateParams) Reset added in v0.0.3 

func (x *MsgUpdateParams) Reset()

func (*MsgUpdateParams) String added in v0.0.3 

func (x *MsgUpdateParams) String() string

type MsgUpdateParamsResponse added in v0.0.3 

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

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use MsgUpdateParamsResponse.ProtoReflect.Descriptor instead.

func (*MsgUpdateParamsResponse) ProtoMessage added in v0.0.3 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) ProtoReflect added in v0.0.3 

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

func (*MsgUpdateParamsResponse) Reset added in v0.0.3 

func (x *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) String added in v0.0.3 

func (x *MsgUpdateParamsResponse) String() string

type Params added in v0.0.3 

type Params struct {

	// num_blocks_per_session is the number of blocks between the session start & end heights.
	NumBlocksPerSession uint64 `protobuf:"varint,1,opt,name=num_blocks_per_session,json=numBlocksPerSession,proto3" json:"num_blocks_per_session,omitempty"`
	// grace_period_end_offset_blocks is the number of blocks, after the session end height,
	// during which the supplier can still service payable relays.
	// Suppliers will need to recreate a claim for the previous session (if already created) to
	// get paid for the additional relays.
	GracePeriodEndOffsetBlocks uint64 `` /* 146-byte string literal not displayed */
	// claim_window_open_offset_blocks is the number of blocks after the session grace
	// period height, at which the claim window opens.
	ClaimWindowOpenOffsetBlocks uint64 `` /* 149-byte string literal not displayed */
	// claim_window_close_offset_blocks is the number of blocks after the claim window
	// open height, at which the claim window closes.
	ClaimWindowCloseOffsetBlocks uint64 `` /* 152-byte string literal not displayed */
	// proof_window_open_offset_blocks is the number of blocks after the claim window
	// close height, at which the proof window opens.
	ProofWindowOpenOffsetBlocks uint64 `` /* 149-byte string literal not displayed */
	// proof_window_close_offset_blocks is the number of blocks after the proof window
	// open height, at which the proof window closes.
	ProofWindowCloseOffsetBlocks uint64 `` /* 152-byte string literal not displayed */
	// supplier_unbonding_period_sessions is the number of sessions that a supplier must wait after
	// unstaking before their staked assets are moved to their account balance.
	// On-chain business logic requires, and ensures, that the corresponding block count of the unbonding
	// period will exceed the end of any active claim & proof lifecycles.
	SupplierUnbondingPeriodSessions uint64 `` /* 159-byte string literal not displayed */
	// application_unbonding_period_sessions is the number of sessions that an application must wait after
	// unstaking before their staked assets are moved to their account balance.
	// On-chain business logic requires, and ensures, that the corresponding block count of the
	// application unbonding period will exceed the end of its corresponding proof window close height.
	ApplicationUnbondingPeriodSessions uint64 `` /* 168-byte string literal not displayed */
	// The amount of upokt that a compute unit should translate to when settling a session.
	// DEV_NOTE: This used to be under x/tokenomics but has been moved here to avoid cyclic dependencies.
	ComputeUnitsToTokensMultiplier uint64 `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

Params defines the parameters for the module.

func (*Params) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use Params.ProtoReflect.Descriptor instead.

func (*Params) GetApplicationUnbondingPeriodSessions added in v0.0.7 

func (x *Params) GetApplicationUnbondingPeriodSessions() uint64

func (*Params) GetClaimWindowCloseOffsetBlocks added in v0.0.3 

func (x *Params) GetClaimWindowCloseOffsetBlocks() uint64

func (*Params) GetClaimWindowOpenOffsetBlocks added in v0.0.3 

func (x *Params) GetClaimWindowOpenOffsetBlocks() uint64

func (*Params) GetComputeUnitsToTokensMultiplier added in v0.0.10 

func (x *Params) GetComputeUnitsToTokensMultiplier() uint64

func (*Params) GetGracePeriodEndOffsetBlocks added in v0.0.3 

func (x *Params) GetGracePeriodEndOffsetBlocks() uint64

func (*Params) GetNumBlocksPerSession added in v0.0.3 

func (x *Params) GetNumBlocksPerSession() uint64

func (*Params) GetProofWindowCloseOffsetBlocks added in v0.0.3 

func (x *Params) GetProofWindowCloseOffsetBlocks() uint64

func (*Params) GetProofWindowOpenOffsetBlocks added in v0.0.3 

func (x *Params) GetProofWindowOpenOffsetBlocks() uint64

func (*Params) GetSupplierUnbondingPeriodSessions added in v0.0.6 

func (x *Params) GetSupplierUnbondingPeriodSessions() uint64

func (*Params) ProtoMessage added in v0.0.3 

func (*Params) ProtoMessage()

func (*Params) ProtoReflect added in v0.0.3 

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

func (*Params) Reset added in v0.0.3 

func (x *Params) Reset()

func (*Params) String added in v0.0.3 

func (x *Params) String() string

type QueryClient added in v0.0.3 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryClient is the client API for Query 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.

Query defines the gRPC querier service.

func NewQueryClient added in v0.0.3 

func NewQueryClient(cc grpc.ClientConnInterface) QueryClient

type QueryParamsRequest added in v0.0.3 

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

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use QueryParamsRequest.ProtoReflect.Descriptor instead.

func (*QueryParamsRequest) ProtoMessage added in v0.0.3 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) ProtoReflect added in v0.0.3 

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

func (*QueryParamsRequest) Reset added in v0.0.3 

func (x *QueryParamsRequest) Reset()

func (*QueryParamsRequest) String added in v0.0.3 

func (x *QueryParamsRequest) String() string

type QueryParamsResponse added in v0.0.3 

type QueryParamsResponse struct {

	// params holds all the parameters of this module.
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor deprecated added in v0.0.3 

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

Deprecated: Use QueryParamsResponse.ProtoReflect.Descriptor instead.

func (*QueryParamsResponse) GetParams added in v0.0.3 

func (x *QueryParamsResponse) GetParams() *Params

func (*QueryParamsResponse) ProtoMessage added in v0.0.3 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) ProtoReflect added in v0.0.3 

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

func (*QueryParamsResponse) Reset added in v0.0.3 

func (x *QueryParamsResponse) Reset()

func (*QueryParamsResponse) String added in v0.0.3 

func (x *QueryParamsResponse) String() string

type QueryServer added in v0.0.3 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// contains filtered or unexported methods
}

QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility

Query defines the gRPC querier service.

type RPCType 

type RPCType int32

Enum to define RPC types 

const (
	RPCType_UNKNOWN_RPC RPCType = 0 // Undefined RPC type
	RPCType_GRPC        RPCType = 1 // gRPC
	RPCType_WEBSOCKET   RPCType = 2 // WebSocket
	RPCType_JSON_RPC    RPCType = 3 // JSON-RPC
	RPCType_REST        RPCType = 4 // REST
)

func (RPCType) Descriptor 

func (RPCType) Descriptor() protoreflect.EnumDescriptor

func (RPCType) Enum 

func (x RPCType) Enum() *RPCType

func (RPCType) EnumDescriptor deprecated 

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

Deprecated: Use RPCType.Descriptor instead.

func (RPCType) Number 

func (x RPCType) Number() protoreflect.EnumNumber

func (RPCType) String 

func (x RPCType) String() string

func (RPCType) Type 

func (RPCType) Type() protoreflect.EnumType

type Service 

type Service struct {

	// For example, what if we want to request a session for a certain service but with some additional configs that identify it?
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // Unique identifier for the service
	// TODO_BETA(@bryanchriswhite): Either remove this or rename it to alias.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // (Optional) Semantic human readable name for the service
	// The cost of a single relay for this service in terms of compute units.
	// Must be used alongside the global 'compute_units_to_tokens_multipler' to calculate the cost of a relay for this service.
	// cost_per_relay_for_specific_service = compute_units_per_relay_for_specific_service * compute_units_to_tokens_multipler_global_value
	ComputeUnitsPerRelay uint64 `` // Compute units required per relay for this service
	/* 126-byte string literal not displayed */
	// The owner address that created the service.
	// It is the address that receives rewards based on the Service's on-chain usage
	// It is the only address that can update the service configuration (e.g. compute_units_per_relay),
	// or make other updates to it.
	OwnerAddress string `protobuf:"bytes,4,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"` // The Bech32 address of the service owner / creator
	// contains filtered or unexported fields
}

Service message to encapsulate unique and semantic identifiers for a service on the network

func (*Service) Descriptor deprecated 

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

Deprecated: Use Service.ProtoReflect.Descriptor instead.

func (*Service) GetComputeUnitsPerRelay added in v0.0.5 

func (x *Service) GetComputeUnitsPerRelay() uint64

func (*Service) GetId 

func (x *Service) GetId() string

func (*Service) GetName 

func (x *Service) GetName() string

func (*Service) GetOwnerAddress added in v0.0.5 

func (x *Service) GetOwnerAddress() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) ProtoReflect 

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

func (*Service) Reset 

func (x *Service) Reset()

func (*Service) String 

func (x *Service) String() string

type ServiceRevenueShare added in v0.0.6 

type ServiceRevenueShare struct {
	Address            string  `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`                                                     // The Bech32 address of the revenue share recipient
	RevSharePercentage float32 `protobuf:"fixed32,2,opt,name=rev_share_percentage,json=revSharePercentage,proto3" json:"rev_share_percentage,omitempty"` // The percentage of revenue share the recipient will receive
	// contains filtered or unexported fields
}

ServiceRevenueShare message to hold revenue share configuration details

func (*ServiceRevenueShare) Descriptor deprecated added in v0.0.6 

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

Deprecated: Use ServiceRevenueShare.ProtoReflect.Descriptor instead.

func (*ServiceRevenueShare) GetAddress added in v0.0.6 

func (x *ServiceRevenueShare) GetAddress() string

func (*ServiceRevenueShare) GetRevSharePercentage added in v0.0.6 

func (x *ServiceRevenueShare) GetRevSharePercentage() float32

func (*ServiceRevenueShare) ProtoMessage added in v0.0.6 

func (*ServiceRevenueShare) ProtoMessage()

func (*ServiceRevenueShare) ProtoReflect added in v0.0.6 

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

func (*ServiceRevenueShare) Reset added in v0.0.6 

func (x *ServiceRevenueShare) Reset()

func (*ServiceRevenueShare) String added in v0.0.6 

func (x *ServiceRevenueShare) String() string

type Supplier 

type Supplier struct {

	// The address of the owner (i.e. staker, custodial) that owns the funds for staking.
	// By default, this address is the one that receives all the rewards unless owtherwise specified.
	// This property cannot be updated by the operator.
	OwnerAddress string `protobuf:"bytes,1,opt,name=owner_address,json=ownerAddress,proto3" json:"owner_address,omitempty"` // Bech32 cosmos address
	// The operator address of the supplier operator (i.e. the one managing the off-chain server).
	// The operator address can update the supplier's configurations excluding the owner address.
	// This property does not change over the supplier's lifespan, the supplier must be unstaked
	// and re-staked to effectively update this value.
	OperatorAddress string                   `protobuf:"bytes,2,opt,name=operator_address,json=operatorAddress,proto3" json:"operator_address,omitempty"` // Bech32 cosmos address
	Stake           *v1beta1.Coin            `protobuf:"bytes,3,opt,name=stake,proto3" json:"stake,omitempty"`                                            // The total amount of uPOKT the supplier has staked
	Services        []*SupplierServiceConfig `protobuf:"bytes,4,rep,name=services,proto3" json:"services,omitempty"`                                      // The service configs this supplier can support
	// The session end height at which an actively unbonding supplier unbonds its stake.
	// If the supplier did not unstake, this value will be 0.
	UnstakeSessionEndHeight uint64 `` /* 135-byte string literal not displayed */
	// services_activation_heights_map is a map of serviceIds to the height at
	// which the staked supplier will become active for that service.
	// Activation heights are session start heights.
	ServicesActivationHeightsMap map[string]uint64 `` /* 238-byte string literal not displayed */
	// contains filtered or unexported fields
}

Supplier is the type defining the actor in Pocket Network that provides RPC services.

func (*Supplier) Descriptor deprecated 

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

Deprecated: Use Supplier.ProtoReflect.Descriptor instead.

func (*Supplier) GetOperatorAddress added in v0.0.6 

func (x *Supplier) GetOperatorAddress() string

func (*Supplier) GetOwnerAddress added in v0.0.6 

func (x *Supplier) GetOwnerAddress() string

func (*Supplier) GetServices 

func (x *Supplier) GetServices() []*SupplierServiceConfig

func (*Supplier) GetServicesActivationHeightsMap added in v0.0.6 

func (x *Supplier) GetServicesActivationHeightsMap() map[string]uint64

func (*Supplier) GetStake 

func (x *Supplier) GetStake() *v1beta1.Coin

func (*Supplier) GetUnstakeSessionEndHeight added in v0.0.5 

func (x *Supplier) GetUnstakeSessionEndHeight() uint64

func (*Supplier) ProtoMessage 

func (*Supplier) ProtoMessage()

func (*Supplier) ProtoReflect 

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

func (*Supplier) Reset 

func (x *Supplier) Reset()

func (*Supplier) String 

func (x *Supplier) String() string

type SupplierEndpoint 

type SupplierEndpoint struct {
	Url     string          `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`                                                      // URL of the endpoint
	RpcType RPCType         `protobuf:"varint,2,opt,name=rpc_type,json=rpcType,proto3,enum=poktroll.shared.RPCType" json:"rpc_type,omitempty"` // Type of RPC exposed on the url above
	Configs []*ConfigOption `protobuf:"bytes,3,rep,name=configs,proto3" json:"configs,omitempty"`                                              // Additional configuration options for the endpoint
	// contains filtered or unexported fields
}

SupplierEndpoint message to hold service configuration details

func (*SupplierEndpoint) Descriptor deprecated 

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

Deprecated: Use SupplierEndpoint.ProtoReflect.Descriptor instead.

func (*SupplierEndpoint) GetConfigs 

func (x *SupplierEndpoint) GetConfigs() []*ConfigOption

func (*SupplierEndpoint) GetRpcType 

func (x *SupplierEndpoint) GetRpcType() RPCType

func (*SupplierEndpoint) GetUrl 

func (x *SupplierEndpoint) GetUrl() string

func (*SupplierEndpoint) ProtoMessage 

func (*SupplierEndpoint) ProtoMessage()

func (*SupplierEndpoint) ProtoReflect 

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

func (*SupplierEndpoint) Reset 

func (x *SupplierEndpoint) Reset()

func (*SupplierEndpoint) String 

func (x *SupplierEndpoint) String() string

type SupplierServiceConfig 

type SupplierServiceConfig struct {
	ServiceId string                 `protobuf:"bytes,1,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"` // The Service ID for which the supplier is configured
	Endpoints []*SupplierEndpoint    `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`                  // List of endpoints for the service
	RevShare  []*ServiceRevenueShare `protobuf:"bytes,3,rep,name=rev_share,json=revShare,proto3" json:"rev_share,omitempty"`    // List of revenue share configurations for the service
	// contains filtered or unexported fields
}

SupplierServiceConfig holds the service configuration the supplier stakes for

func (*SupplierServiceConfig) Descriptor deprecated 

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

Deprecated: Use SupplierServiceConfig.ProtoReflect.Descriptor instead.

func (*SupplierServiceConfig) GetEndpoints 

func (x *SupplierServiceConfig) GetEndpoints() []*SupplierEndpoint

func (*SupplierServiceConfig) GetRevShare added in v0.0.6 

func (x *SupplierServiceConfig) GetRevShare() []*ServiceRevenueShare

func (*SupplierServiceConfig) GetServiceId added in v0.0.8 

func (x *SupplierServiceConfig) GetServiceId() string

func (*SupplierServiceConfig) ProtoMessage 

func (*SupplierServiceConfig) ProtoMessage()

func (*SupplierServiceConfig) ProtoReflect 

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

func (*SupplierServiceConfig) Reset 

func (x *SupplierServiceConfig) Reset()

func (*SupplierServiceConfig) String 

func (x *SupplierServiceConfig) String() string

type UnimplementedMsgServer added in v0.0.3 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

func (UnimplementedMsgServer) UpdateParam added in v0.0.3 

func (UnimplementedMsgServer) UpdateParam(context.Context, *MsgUpdateParam) (*MsgUpdateParamResponse, error)

func (UnimplementedMsgServer) UpdateParams added in v0.0.3 

func (UnimplementedMsgServer) UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer added in v0.0.3 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) Params added in v0.0.3 

func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)

type UnsafeMsgServer added in v0.0.3 

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

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

type UnsafeQueryServer added in v0.0.3 

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

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

Source Files

View all Source files

Directories

Path Synopsis
Code generated by protoc-gen-go-pulsar.
 Code generated by protoc-gen-go-pulsar.

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.