resumefollow

package
v8.13.1 Latest Latest
Warning

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

 Go to latest Published: Apr 11, 2024 License: Apache-2.0 Imports: 12 Imported by: 3

Documentation

Overview

Resumes a follower index that has been paused

Index

Constants

This section is empty.

Variables

View Source 
var ErrBuildPath = errors.New("cannot build path, check for missing path parameters")

ErrBuildPath is returned in case of missing parameters within the build of the request.

Functions

This section is empty.

Types

type NewResumeFollow 

type NewResumeFollow func(index string) *ResumeFollow

NewResumeFollow type alias for index.

func NewResumeFollowFunc 

func NewResumeFollowFunc(tp elastictransport.Interface) NewResumeFollow

NewResumeFollowFunc returns a new instance of ResumeFollow with the provided transport. Used in the index of the library this allows to retrieve every apis in once place.

type Request 

type Request struct {
	MaxOutstandingReadRequests    *int64         `json:"max_outstanding_read_requests,omitempty"`
	MaxOutstandingWriteRequests   *int64         `json:"max_outstanding_write_requests,omitempty"`
	MaxReadRequestOperationCount  *int64         `json:"max_read_request_operation_count,omitempty"`
	MaxReadRequestSize            *string        `json:"max_read_request_size,omitempty"`
	MaxRetryDelay                 types.Duration `json:"max_retry_delay,omitempty"`
	MaxWriteBufferCount           *int64         `json:"max_write_buffer_count,omitempty"`
	MaxWriteBufferSize            *string        `json:"max_write_buffer_size,omitempty"`
	MaxWriteRequestOperationCount *int64         `json:"max_write_request_operation_count,omitempty"`
	MaxWriteRequestSize           *string        `json:"max_write_request_size,omitempty"`
	ReadPollTimeout               types.Duration `json:"read_poll_timeout,omitempty"`
}

Request holds the request body struct for the package resumefollow

https://github.com/elastic/elasticsearch-specification/blob/5bf86339cd4bda77d07f6eaa6789b72f9c0279b1/specification/ccr/resume_follow/ResumeFollowIndexRequest.ts#L25-L46

func NewRequest added in v8.5.0 

func NewRequest() *Request

NewRequest returns a Request

func (*Request) FromJSON added in v8.5.0 

func (r *Request) FromJSON(data string) (*Request, error)

FromJSON allows to load an arbitrary json into the request structure

func (*Request) UnmarshalJSON added in v8.12.1 

func (s *Request) UnmarshalJSON(data []byte) error

type Response added in v8.7.0 

type Response struct {

	// Acknowledged For a successful response, this value is always true. On failure, an
	// exception is returned instead.
	Acknowledged bool `json:"acknowledged"`
}

Response holds the response body struct for the package resumefollow

https://github.com/elastic/elasticsearch-specification/blob/5bf86339cd4bda77d07f6eaa6789b72f9c0279b1/specification/ccr/resume_follow/ResumeFollowIndexResponse.ts#L22-L24

func NewResponse added in v8.7.0 

func NewResponse() *Response

NewResponse returns a Response

type ResumeFollow 

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

func New 

func New(tp elastictransport.Interface) *ResumeFollow

Resumes a follower index that has been paused

https://www.elastic.co/guide/en/elasticsearch/reference/current/ccr-post-resume-follow.html

func (ResumeFollow) Do 

func (r ResumeFollow) Do(providedCtx context.Context) (*Response, error)

Do runs the request through the transport, handle the response and returns a resumefollow.Response

func (*ResumeFollow) Header 

func (r *ResumeFollow) Header(key, value string) *ResumeFollow

Header set a key, value pair in the ResumeFollow headers map.

func (*ResumeFollow) HttpRequest 

func (r *ResumeFollow) HttpRequest(ctx context.Context) (*http.Request, error)

HttpRequest returns the http.Request object built from the given parameters.

func (*ResumeFollow) MaxOutstandingReadRequests added in v8.9.0 

func (r *ResumeFollow) MaxOutstandingReadRequests(maxoutstandingreadrequests int64) *ResumeFollow

API name: max_outstanding_read_requests

func (*ResumeFollow) MaxOutstandingWriteRequests added in v8.9.0 

func (r *ResumeFollow) MaxOutstandingWriteRequests(maxoutstandingwriterequests int64) *ResumeFollow

API name: max_outstanding_write_requests

func (*ResumeFollow) MaxReadRequestOperationCount added in v8.9.0 

func (r *ResumeFollow) MaxReadRequestOperationCount(maxreadrequestoperationcount int64) *ResumeFollow

API name: max_read_request_operation_count

func (*ResumeFollow) MaxReadRequestSize added in v8.9.0 

func (r *ResumeFollow) MaxReadRequestSize(maxreadrequestsize string) *ResumeFollow

API name: max_read_request_size

func (*ResumeFollow) MaxRetryDelay added in v8.9.0 

func (r *ResumeFollow) MaxRetryDelay(duration types.Duration) *ResumeFollow

API name: max_retry_delay

func (*ResumeFollow) MaxWriteBufferCount added in v8.9.0 

func (r *ResumeFollow) MaxWriteBufferCount(maxwritebuffercount int64) *ResumeFollow

API name: max_write_buffer_count

func (*ResumeFollow) MaxWriteBufferSize added in v8.9.0 

func (r *ResumeFollow) MaxWriteBufferSize(maxwritebuffersize string) *ResumeFollow

API name: max_write_buffer_size

func (*ResumeFollow) MaxWriteRequestOperationCount added in v8.9.0 

func (r *ResumeFollow) MaxWriteRequestOperationCount(maxwriterequestoperationcount int64) *ResumeFollow

API name: max_write_request_operation_count

func (*ResumeFollow) MaxWriteRequestSize added in v8.9.0 

func (r *ResumeFollow) MaxWriteRequestSize(maxwriterequestsize string) *ResumeFollow

API name: max_write_request_size

func (ResumeFollow) Perform added in v8.7.0 

func (r ResumeFollow) Perform(providedCtx context.Context) (*http.Response, error)

Perform runs the http.Request through the provided transport and returns an http.Response.

func (*ResumeFollow) Raw 

func (r *ResumeFollow) Raw(raw io.Reader) *ResumeFollow

Raw takes a json payload as input which is then passed to the http.Request If specified Raw takes precedence on Request method.

func (*ResumeFollow) ReadPollTimeout added in v8.9.0 

func (r *ResumeFollow) ReadPollTimeout(duration types.Duration) *ResumeFollow

API name: read_poll_timeout

func (*ResumeFollow) Request 

func (r *ResumeFollow) Request(req *Request) *ResumeFollow

Request allows to set the request property with the appropriate payload.

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.