client

package

Go to main page

Versions in this module

v0

v0.0.30

Apr 2, 2026

Changes in this version

type PeerSource

+ Endpoints []string

type PeerSourceType

+ const PeerSourceDNSEndpoints

v0.0.29

Apr 2, 2026

v0.0.28

Apr 2, 2026

Changes in this version

+ const TaskTypeAssembleGenesisFork

+ const TaskTypeExportState

v0.0.27

Apr 1, 2026

Changes in this version

type SnapshotRestoreTask

+ TargetHeight int64

v0.0.26

Mar 31, 2026

Changes in this version

type AssembleAndUploadGenesisTask

+ AccountBalance string

+ Namespace string

v0.0.25

Mar 30, 2026

v0.0.24

Mar 27, 2026

Changes in this version

type ResultExportTask

+ CanonicalRPC string

v0.0.23

Mar 27, 2026

Changes in this version

+ const TaskTypeSetGenesisPeers

v0.0.22

Mar 26, 2026

Changes in this version

type SidecarClient

+ func (c *SidecarClient) SubmitAssembleAndUploadGenesisTask(ctx context.Context, task AssembleAndUploadGenesisTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitGenerateGentxTask(ctx context.Context, task GenerateGentxTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitGenerateIdentityTask(ctx context.Context, task GenerateIdentityTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitUploadGenesisArtifactsTask(ctx context.Context, task UploadGenesisArtifactsTask) (uuid.UUID, error)

+ type TaskMeta struct

+ ID *uuid.UUID

type TaskRequest

+ Id *openapi_types.UUID

v0.0.21

Mar 25, 2026

Changes in this version

+ const TaskTypeAssembleGenesis

+ const TaskTypeGenerateGentx

+ const TaskTypeGenerateIdentity

+ const TaskTypeUploadGenesisArtifacts

+ type AssembleAndUploadGenesisTask struct

+ ChainID string

+ Nodes []GenesisNodeParam

+ S3Bucket string

+ S3Prefix string

+ S3Region string

+ func (t AssembleAndUploadGenesisTask) TaskType() string

+ func (t AssembleAndUploadGenesisTask) ToTaskRequest() TaskRequest

+ func (t AssembleAndUploadGenesisTask) Validate() error

+ type GenerateGentxTask struct

+ AccountBalance string

+ ChainID string

+ GenesisParams string

+ StakingAmount string

+ func (t GenerateGentxTask) TaskType() string

+ func (t GenerateGentxTask) ToTaskRequest() TaskRequest

+ func (t GenerateGentxTask) Validate() error

+ type GenerateIdentityTask struct

+ ChainID string

+ Moniker string

+ func (t GenerateIdentityTask) TaskType() string

+ func (t GenerateIdentityTask) ToTaskRequest() TaskRequest

+ func (t GenerateIdentityTask) Validate() error

+ type GenesisNodeParam struct

+ Name string

type SidecarClient

+ func (c *SidecarClient) GetNodeID(ctx context.Context) (string, error)

+ type UploadGenesisArtifactsTask struct

+ NodeName string

+ S3Bucket string

+ S3Prefix string

+ S3Region string

+ func (t UploadGenesisArtifactsTask) TaskType() string

+ func (t UploadGenesisArtifactsTask) ToTaskRequest() TaskRequest

+ func (t UploadGenesisArtifactsTask) Validate() error

v0.0.20

Mar 19, 2026

Changes in this version

type SidecarClient

+ func (c *SidecarClient) SubmitAwaitConditionTask(ctx context.Context, task AwaitConditionTask) (uuid.UUID, error)

v0.0.19

Mar 19, 2026

Changes in this version

+ const ActionSIGTERM

+ const ConditionHeight

+ const TaskTypeAwaitCondition

+ type AwaitConditionTask struct

+ Action string

+ Condition string

+ TargetHeight int64

+ func (t AwaitConditionTask) TaskType() string

+ func (t AwaitConditionTask) ToTaskRequest() TaskRequest

+ func (t AwaitConditionTask) Validate() error

v0.0.18

Mar 18, 2026

Changes in this version

type ResultExportTask

+ Schedule *ScheduleConfig

type SnapshotUploadTask

+ Schedule *ScheduleConfig

type TaskResultStatus

+ const Completed

+ const Failed

v0.0.17

Mar 18, 2026

Changes in this version

+ type AsyncConfig struct

+ Daemon *DaemonConfig

+ Schedule *ScheduleConfig

+ type DaemonConfig = map[string]interface

type ResultExportTask

+ Async *AsyncConfig

+ type ScheduleConfig struct

+ BlockHeight *int64

+ Cron *string

type SidecarClient

+ func (c *SidecarClient) SubmitConfigApplyTask(ctx context.Context, task ConfigApplyTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitConfigPatchTask(ctx context.Context, task ConfigPatchTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitConfigReloadTask(ctx context.Context, task ConfigReloadTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitConfigValidateTask(ctx context.Context, task ConfigValidateTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitConfigureGenesisTask(ctx context.Context, task ConfigureGenesisTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitConfigureStateSyncTask(ctx context.Context, task ConfigureStateSyncTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitDiscoverPeersTask(ctx context.Context, task DiscoverPeersTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitMarkReadyTask(ctx context.Context, task MarkReadyTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitResultExportTask(ctx context.Context, task ResultExportTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitSnapshotRestoreTask(ctx context.Context, task SnapshotRestoreTask) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitSnapshotUploadTask(ctx context.Context, task SnapshotUploadTask) (uuid.UUID, error)

type SnapshotUploadTask

+ Async *AsyncConfig

type TaskRequest

+ Async *AsyncConfig

type TaskResult

+ Async *AsyncConfig

v0.0.16

Mar 17, 2026

Changes in this version

+ const TaskTypeResultExport

+ type ResultExportTask struct

+ Bucket string

+ Prefix string

+ Region string

+ func ResultExportTaskFromParams(params map[string]interface{}) ResultExportTask

+ func (t ResultExportTask) TaskType() string

+ func (t ResultExportTask) ToTaskRequest() TaskRequest

+ func (t ResultExportTask) Validate() error

v0.0.15

Mar 17, 2026

Changes in this version

type StatusResponseStatus

+ const StatusResponseStatusInitializing

+ const StatusResponseStatusReady

+ const StatusResponseStatusRunning

type TaskResult

+ Status TaskResultStatus

+ type TaskResultStatus string

+ const TaskResultStatusCompleted

+ const TaskResultStatusFailed

+ const TaskResultStatusRunning

v0.0.14

Mar 15, 2026

Changes in this version

type ConfigureStateSyncTask

+ BackfillBlocks int64

+ TrustPeriod string

v0.0.13

Mar 15, 2026

Changes in this version

type ConfigureStateSyncTask

+ UseLocalSnapshot bool

v0.0.12

Mar 13, 2026

v0.0.11

Mar 13, 2026

v0.0.10

Mar 13, 2026

v0.0.9

Mar 12, 2026

Changes in this version

+ const TaskTypeConfigApply

+ const TaskTypeConfigReload

+ const TaskTypeConfigValidate

+ type ConfigApplyTask struct

+ Intent seiconfig.ConfigIntent

+ func ConfigApplyTaskFromParams(params map[string]interface{}) ConfigApplyTask

+ func (t ConfigApplyTask) TaskType() string

+ func (t ConfigApplyTask) ToTaskRequest() TaskRequest

+ func (t ConfigApplyTask) Validate() error

+ type ConfigReloadTask struct

+ Fields map[string]string

+ func ConfigReloadTaskFromParams(params map[string]interface{}) ConfigReloadTask

+ func (t ConfigReloadTask) TaskType() string

+ func (t ConfigReloadTask) ToTaskRequest() TaskRequest

+ func (t ConfigReloadTask) Validate() error

+ type ConfigValidateTask struct

+ func (t ConfigValidateTask) TaskType() string

+ func (t ConfigValidateTask) ToTaskRequest() TaskRequest

+ func (t ConfigValidateTask) Validate() error

v0.0.8

Mar 8, 2026

Changes in this version

type SnapshotUploadTask

+ Cron string

v0.0.7

Mar 6, 2026

Changes in this version

type ConfigPatchTask

+ Files map[string]map[string]any

v0.0.6

Mar 5, 2026

Changes in this version

+ const DefaultPort

+ const TaskTypeConfigPatch

+ const TaskTypeConfigureGenesis

+ const TaskTypeConfigureStateSync

+ const TaskTypeDiscoverPeers

+ const TaskTypeMarkReady

+ const TaskTypeSnapshotRestore

+ const TaskTypeSnapshotUpload

+ const TaskTypeUpdatePeers

+ var ErrBusy = errors.New("sidecar: task already running")

+ var ErrNotFound = errors.New("sidecar: task not found")

+ func NewDeleteTaskRequest(server string, id openapi_types.UUID) (*http.Request, error)

+ func NewGetStatusRequest(server string) (*http.Request, error)

+ func NewGetTaskRequest(server string, id openapi_types.UUID) (*http.Request, error)

+ func NewHealthzRequest(server string) (*http.Request, error)

+ func NewListTasksRequest(server string) (*http.Request, error)

+ func NewSubmitTaskRequest(server string, body SubmitTaskJSONRequestBody) (*http.Request, error)

+ func NewSubmitTaskRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ type Client struct

+ Client HttpRequestDoer

+ RequestEditors []RequestEditorFn

+ Server string

+ func NewClient(server string, opts ...ClientOption) (*Client, error)

+ func (c *Client) DeleteTask(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetStatus(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetTask(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) Healthz(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) ListTasks(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) SubmitTask(ctx context.Context, body SubmitTaskJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) SubmitTaskWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientInterface interface

+ DeleteTask func(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetStatus func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetTask func(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*http.Response, error)

+ Healthz func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ ListTasks func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ SubmitTask func(ctx context.Context, body SubmitTaskJSONRequestBody, ...) (*http.Response, error)

+ SubmitTaskWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientOption func(*Client) error

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(doer HttpRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type ClientWithResponses struct

+ func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

+ func (c *ClientWithResponses) DeleteTaskWithResponse(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*DeleteTaskResponse, error)

+ func (c *ClientWithResponses) GetStatusWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetStatusResponse, error)

+ func (c *ClientWithResponses) GetTaskWithResponse(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*GetTaskResponse, error)

+ func (c *ClientWithResponses) HealthzWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthzResponse, error)

+ func (c *ClientWithResponses) ListTasksWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*ListTasksResponse, error)

+ func (c *ClientWithResponses) SubmitTaskWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*SubmitTaskResponse, error)

+ func (c *ClientWithResponses) SubmitTaskWithResponse(ctx context.Context, body SubmitTaskJSONRequestBody, ...) (*SubmitTaskResponse, error)

+ type ClientWithResponsesInterface interface

+ DeleteTaskWithResponse func(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*DeleteTaskResponse, error)

+ GetStatusWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetStatusResponse, error)

+ GetTaskWithResponse func(ctx context.Context, id openapi_types.UUID, reqEditors ...RequestEditorFn) (*GetTaskResponse, error)

+ HealthzWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*HealthzResponse, error)

+ ListTasksWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*ListTasksResponse, error)

+ SubmitTaskWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*SubmitTaskResponse, error)

+ SubmitTaskWithResponse func(ctx context.Context, body SubmitTaskJSONRequestBody, ...) (*SubmitTaskResponse, error)

+ type ConfigPatchTask struct

+ NodeMode string

+ Peers []string

+ SnapshotGeneration *SnapshotGenerationPatch

+ func ConfigPatchTaskFromParams(params map[string]interface{}) ConfigPatchTask

+ func (t ConfigPatchTask) TaskType() string

+ func (t ConfigPatchTask) ToTaskRequest() TaskRequest

+ func (t ConfigPatchTask) Validate() error

+ type ConfigureGenesisTask struct

+ Region string

+ URI string

+ func ConfigureGenesisTaskFromParams(params map[string]interface{}) ConfigureGenesisTask

+ func (t ConfigureGenesisTask) TaskType() string

+ func (t ConfigureGenesisTask) ToTaskRequest() TaskRequest

+ func (t ConfigureGenesisTask) Validate() error

+ type ConfigureStateSyncTask struct

+ func (t ConfigureStateSyncTask) TaskType() string

+ func (t ConfigureStateSyncTask) ToTaskRequest() TaskRequest

+ func (t ConfigureStateSyncTask) Validate() error

+ type DeleteTaskResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON404 *ErrorResponse

+ func ParseDeleteTaskResponse(rsp *http.Response) (*DeleteTaskResponse, error)

+ func (r DeleteTaskResponse) Status() string

+ func (r DeleteTaskResponse) StatusCode() int

+ type DiscoverPeersTask struct

+ Sources []PeerSource

+ func DiscoverPeersTaskFromParams(params map[string]interface{}) (DiscoverPeersTask, error)

+ func (t DiscoverPeersTask) TaskType() string

+ func (t DiscoverPeersTask) ToTaskRequest() TaskRequest

+ func (t DiscoverPeersTask) Validate() error

+ type ErrorResponse struct

+ Error string

+ type GetStatusResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *StatusResponse

+ func ParseGetStatusResponse(rsp *http.Response) (*GetStatusResponse, error)

+ func (r GetStatusResponse) Status() string

+ func (r GetStatusResponse) StatusCode() int

+ type GetTaskResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *TaskResult

+ JSON404 *ErrorResponse

+ func ParseGetTaskResponse(rsp *http.Response) (*GetTaskResponse, error)

+ func (r GetTaskResponse) Status() string

+ func (r GetTaskResponse) StatusCode() int

+ type HealthzResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseHealthzResponse(rsp *http.Response) (*HealthzResponse, error)

+ func (r HealthzResponse) Status() string

+ func (r HealthzResponse) StatusCode() int

+ type HttpRequestDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type ListTasksResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON200 *[]TaskResult

+ func ParseListTasksResponse(rsp *http.Response) (*ListTasksResponse, error)

+ func (r ListTasksResponse) Status() string

+ func (r ListTasksResponse) StatusCode() int

+ type MarkReadyTask struct

+ func (t MarkReadyTask) TaskType() string

+ func (t MarkReadyTask) ToTaskRequest() TaskRequest

+ func (t MarkReadyTask) Validate() error

+ type Option func(*sidecarOpts)

+ func WithHTTPDoer(doer HttpRequestDoer) Option

+ func WithTimeout(d time.Duration) Option

+ type PeerSource struct

+ Addresses []string

+ Region string

+ Tags map[string]string

+ Type PeerSourceType

+ type PeerSourceType string

+ const PeerSourceEC2Tags

+ const PeerSourceStatic

+ type RequestEditorFn func(ctx context.Context, req *http.Request) error

+ type Schedule struct

+ BlockHeight *int64

+ Cron *string

+ type SidecarClient struct

+ func NewSidecarClient(baseURL string, opts ...Option) (*SidecarClient, error)

+ func NewSidecarClientFromPodDNS(name, namespace string, port int32, opts ...Option) (*SidecarClient, error)

+ func (c *SidecarClient) DeleteTask(ctx context.Context, id uuid.UUID) error

+ func (c *SidecarClient) GetTask(ctx context.Context, id uuid.UUID) (*TaskResult, error)

+ func (c *SidecarClient) Healthz(ctx context.Context) (bool, error)

+ func (c *SidecarClient) ListTasks(ctx context.Context) ([]TaskResult, error)

+ func (c *SidecarClient) Status(ctx context.Context) (*StatusResponse, error)

+ func (c *SidecarClient) SubmitRawTask(ctx context.Context, task TaskRequest) (uuid.UUID, error)

+ func (c *SidecarClient) SubmitTask(ctx context.Context, task TaskBuilder) (uuid.UUID, error)

+ type SnapshotGenerationPatch struct

+ Interval int64

+ KeepRecent int32

+ type SnapshotRestoreTask struct

+ Bucket string

+ ChainID string

+ Prefix string

+ Region string

+ func SnapshotRestoreTaskFromParams(params map[string]interface{}) SnapshotRestoreTask

+ func (t SnapshotRestoreTask) TaskType() string

+ func (t SnapshotRestoreTask) ToTaskRequest() TaskRequest

+ func (t SnapshotRestoreTask) Validate() error

+ type SnapshotUploadTask struct

+ Bucket string

+ Prefix string

+ Region string

+ func SnapshotUploadTaskFromParams(params map[string]interface{}) SnapshotUploadTask

+ func (t SnapshotUploadTask) TaskType() string

+ func (t SnapshotUploadTask) ToTaskRequest() TaskRequest

+ func (t SnapshotUploadTask) Validate() error

+ type StatusResponse struct

+ Status StatusResponseStatus

+ type StatusResponseStatus string

+ const Initializing

+ const Ready

+ const Running

+ type SubmitTaskJSONRequestBody = TaskRequest

+ type SubmitTaskResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ JSON201 *TaskSubmitResponse

+ JSON202 *TaskSubmitResponse

+ JSON400 *ErrorResponse

+ JSON409 *ErrorResponse

+ func ParseSubmitTaskResponse(rsp *http.Response) (*SubmitTaskResponse, error)

+ func (r SubmitTaskResponse) Status() string

+ func (r SubmitTaskResponse) StatusCode() int

+ type TaskBuilder interface

+ TaskType func() string

+ ToTaskRequest func() TaskRequest

+ Validate func() error

+ type TaskRequest struct

+ Params *map[string]interface{}

+ Schedule *Schedule

+ Type string

+ type TaskResult struct

+ CompletedAt *time.Time

+ Error *string

+ Id openapi_types.UUID

+ NextRunAt *time.Time

+ Params *map[string]interface{}

+ Schedule *Schedule

+ SubmittedAt time.Time

+ Type string

+ type TaskSubmitResponse struct

+ Id openapi_types.UUID

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL