dbx_async

Documentation

Index

• type Async
• type AsyncOpt
  • func PollInterval(seconds int) AsyncOpt
  • func Status(endpoint string) AsyncOpt
• type AsyncOpts
  • func Combined(opts []AsyncOpt) AsyncOpts
• type Response
  • func NewCompleted(res es_response.Response, complete es_json.Json) Response
  • func NewIncomplete(res es_response.Response) Response

Types

type Async

type Async interface {
	Call(opts ...AsyncOpt) Response
}

type AsyncOpt

type AsyncOpt func(o AsyncOpts) AsyncOpts

func PollInterval

func PollInterval(seconds int) AsyncOpt

func Status

func Status(endpoint string) AsyncOpt

type AsyncOpts

type AsyncOpts struct {
	PollInterval   int
	StatusEndpoint string
}

func Combined

func Combined(opts []AsyncOpt) AsyncOpts

type Response

type Response interface {
	es_response.Response

	// True when the async job completed.
	IsCompleted() bool

	// Completed body. Returns nil if the operation is not yet completed.
	Complete() es_json.Json
}

func NewCompleted

func NewCompleted(res es_response.Response, complete es_json.Json) Response

func NewIncomplete

func NewIncomplete(res es_response.Response) Response