session

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: May 17, 2024 License: MIT Imports: 15 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.

Index

Constants

This section is empty.

Variables

View Source 
var File_poktroll_session_genesis_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_session_params_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_session_query_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_session_session_proto protoreflect.FileDescriptor
View Source 
var File_poktroll_session_tx_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type GenesisState 

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 session module's genesis state.

func (*GenesisState) Descriptor deprecated 

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

Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.

func (*GenesisState) GetParams 

func (x *GenesisState) GetParams() *Params

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) ProtoReflect 

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

func (*GenesisState) Reset 

func (x *GenesisState) Reset()

func (*GenesisState) String 

func (x *GenesisState) String() string

type MsgUpdateParams 

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"`
	// params defines the x/session parameters to update.
	// 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 

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

Deprecated: Use MsgUpdateParams.ProtoReflect.Descriptor instead.

func (*MsgUpdateParams) GetAuthority 

func (x *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams 

func (x *MsgUpdateParams) GetParams() *Params

func (*MsgUpdateParams) ProtoMessage 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) ProtoReflect 

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

func (*MsgUpdateParams) Reset 

func (x *MsgUpdateParams) Reset()

func (*MsgUpdateParams) String 

func (x *MsgUpdateParams) String() string

type MsgUpdateParamsResponse 

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

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor deprecated 

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

Deprecated: Use MsgUpdateParamsResponse.ProtoReflect.Descriptor instead.

func (*MsgUpdateParamsResponse) ProtoMessage 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) ProtoReflect 

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

func (*MsgUpdateParamsResponse) Reset 

func (x *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) String 

func (x *MsgUpdateParamsResponse) String() string

type Params 

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

Params defines the parameters for the module.

func (*Params) Descriptor deprecated 

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

Deprecated: Use Params.ProtoReflect.Descriptor instead.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) ProtoReflect 

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

func (*Params) Reset 

func (x *Params) Reset()

func (*Params) String 

func (x *Params) String() string

type QueryGetSessionRequest 

type QueryGetSessionRequest struct {
	ApplicationAddress string          `protobuf:"bytes,1,opt,name=application_address,json=applicationAddress,proto3" json:"application_address,omitempty"` // The Bech32 address of the application using cosmos' ScalarDescriptor to ensure deterministic encoding
	Service            *shared.Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`                                                 // The service to query the session for
	BlockHeight        int64           `protobuf:"varint,3,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`                     // The block height to query the session for
	// contains filtered or unexported fields
}

func (*QueryGetSessionRequest) Descriptor deprecated 

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

Deprecated: Use QueryGetSessionRequest.ProtoReflect.Descriptor instead.

func (*QueryGetSessionRequest) GetApplicationAddress 

func (x *QueryGetSessionRequest) GetApplicationAddress() string

func (*QueryGetSessionRequest) GetBlockHeight 

func (x *QueryGetSessionRequest) GetBlockHeight() int64

func (*QueryGetSessionRequest) GetService 

func (x *QueryGetSessionRequest) GetService() *shared.Service

func (*QueryGetSessionRequest) ProtoMessage 

func (*QueryGetSessionRequest) ProtoMessage()

func (*QueryGetSessionRequest) ProtoReflect 

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

func (*QueryGetSessionRequest) Reset 

func (x *QueryGetSessionRequest) Reset()

func (*QueryGetSessionRequest) String 

func (x *QueryGetSessionRequest) String() string

type QueryGetSessionResponse 

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

func (*QueryGetSessionResponse) Descriptor deprecated 

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

Deprecated: Use QueryGetSessionResponse.ProtoReflect.Descriptor instead.

func (*QueryGetSessionResponse) GetSession 

func (x *QueryGetSessionResponse) GetSession() *Session

func (*QueryGetSessionResponse) ProtoMessage 

func (*QueryGetSessionResponse) ProtoMessage()

func (*QueryGetSessionResponse) ProtoReflect 

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

func (*QueryGetSessionResponse) Reset 

func (x *QueryGetSessionResponse) Reset()

func (*QueryGetSessionResponse) String 

func (x *QueryGetSessionResponse) String() string

type QueryParamsRequest 

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

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

func (*QueryParamsRequest) Descriptor deprecated 

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

Deprecated: Use QueryParamsRequest.ProtoReflect.Descriptor instead.

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) ProtoReflect 

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

func (*QueryParamsRequest) Reset 

func (x *QueryParamsRequest) Reset()

func (*QueryParamsRequest) String 

func (x *QueryParamsRequest) String() string

type QueryParamsResponse 

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 

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

Deprecated: Use QueryParamsResponse.ProtoReflect.Descriptor instead.

func (*QueryParamsResponse) GetParams 

func (x *QueryParamsResponse) GetParams() *Params

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) ProtoReflect 

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

func (*QueryParamsResponse) Reset 

func (x *QueryParamsResponse) Reset()

func (*QueryParamsResponse) String 

func (x *QueryParamsResponse) String() string

type Session 

type Session struct {
	Header              *SessionHeader           `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`                                                           // The header of the session containing lightweight data
	SessionId           string                   `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`                                    // A unique pseudoranom ID for this session
	SessionNumber       int64                    `protobuf:"varint,3,opt,name=session_number,json=sessionNumber,proto3" json:"session_number,omitempty"`                       // The session number since genesis
	NumBlocksPerSession int64                    `protobuf:"varint,4,opt,name=num_blocks_per_session,json=numBlocksPerSession,proto3" json:"num_blocks_per_session,omitempty"` // The number of blocks per session when this session started
	Application         *application.Application `protobuf:"bytes,5,opt,name=application,proto3" json:"application,omitempty"`                                                 // A fully hydrated application object this session is for
	Suppliers           []*shared.Supplier       `protobuf:"bytes,6,rep,name=suppliers,proto3" json:"suppliers,omitempty"`                                                     // A fully hydrated set of servicers that are serving the application
	// contains filtered or unexported fields
}

Session is a fully hydrated session object that contains all the information for the Session and its parcipants.

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetApplication 

func (x *Session) GetApplication() *application.Application

func (*Session) GetHeader 

func (x *Session) GetHeader() *SessionHeader

func (*Session) GetNumBlocksPerSession 

func (x *Session) GetNumBlocksPerSession() int64

func (*Session) GetSessionId 

func (x *Session) GetSessionId() string

func (*Session) GetSessionNumber 

func (x *Session) GetSessionNumber() int64

func (*Session) GetSuppliers 

func (x *Session) GetSuppliers() []*shared.Supplier

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionHeader 

type SessionHeader struct {
	ApplicationAddress string          `protobuf:"bytes,1,opt,name=application_address,json=applicationAddress,proto3" json:"application_address,omitempty"` // The Bech32 address of the application using cosmos' ScalarDescriptor to ensure deterministic encoding
	Service            *shared.Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`                                                 // The service this session is for
	// NOTE: session_id can be derived from the above values using on-chain but is included in the header for convenience
	SessionId               string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"` // A unique pseudoranom ID for this session
	SessionStartBlockHeight int64  ``                                                                                         // The height at which this session started
	/* 135-byte string literal not displayed */
	// Note that`session_end_block_height` is a derivative of (`start` + `num_blocks_per_session`)
	// as goverened by on-chain params at the time of the session start.
	// It is stored as an additional field to simplofy business logic in case
	// the number of blocks_per_session changes during the session.
	SessionEndBlockHeight int64 `` // The height at which this session ended, this is the last block of the session
	/* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

SessionHeader is a lightweight header for a session that can be passed around. It is the minimal amount of data required to hydrate & retrieve all data relevant to the session.

func (*SessionHeader) Descriptor deprecated 

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

Deprecated: Use SessionHeader.ProtoReflect.Descriptor instead.

func (*SessionHeader) GetApplicationAddress 

func (x *SessionHeader) GetApplicationAddress() string

func (*SessionHeader) GetService 

func (x *SessionHeader) GetService() *shared.Service

func (*SessionHeader) GetSessionEndBlockHeight 

func (x *SessionHeader) GetSessionEndBlockHeight() int64

func (*SessionHeader) GetSessionId 

func (x *SessionHeader) GetSessionId() string

func (*SessionHeader) GetSessionStartBlockHeight 

func (x *SessionHeader) GetSessionStartBlockHeight() int64

func (*SessionHeader) ProtoMessage 

func (*SessionHeader) ProtoMessage()

func (*SessionHeader) ProtoReflect 

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

func (*SessionHeader) Reset 

func (x *SessionHeader) Reset()

func (*SessionHeader) String 

func (x *SessionHeader) String() string

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.