Commitaef7e71

committed

feature: added SnapshotAllIndicesWithBodyParams function

1 parent0c26877 commitaef7e71Copy full SHA for aef7e71

File tree

+28

-0

lines changed

+28

-0

lines changed

Lines changed: 28 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1174,6 +1174,34 @@ func (c *Client) SnapshotAllIndices(repository string, snapshot string) error {`
`1174`	`1174`	`returnerr`
`1175`	`1175`	`}`
`1176`	`1176`
	`1177`	`+func (c*Client)SnapshotAllIndicesWithBodyParams(repositorystring,snapshotstring,bodyParamsmap[string]interface{})error {`
	`1178`	`+ifrepository=="" {`
	`1179`	`+returnerrors.New("empty string for repository is not allowed")`
	`1180`	`+}`
	`1181`	`+`
	`1182`	`+ifsnapshot=="" {`
	`1183`	`+returnerrors.New("empty string for snapshot is not allowed")`
	`1184`	`+}`
	`1185`	`+`
	`1186`	`+ifbodyParams==nil {`
	`1187`	`+returnerrors.New("no body params provided, please use SnapshotAllIndices Function instead")`
	`1188`	`+}`
	`1189`	`+`
	`1190`	`+parsedJson,parsingErr:=json.Marshal(bodyParams)`
	`1191`	`+`
	`1192`	`+ifparsingErr!=nil {`
	`1193`	`+returnparsingErr`
	`1194`	`+}`
	`1195`	`+`
	`1196`	`+agent:=c.buildPutRequest(fmt.Sprintf("_snapshot/%s/%s",repository,snapshot)).`
	`1197`	`+Set("Content-Type","application/json").`
	`1198`	`+Send(parsedJson)`
	`1199`	`+`
	`1200`	`+_,err:=handleErrWithBytes(agent)`
	`1201`	`+`
	`1202`	`+returnerr`
	`1203`	`+}`
	`1204`	`+`
`1177`	`1205`	`// Restore an index or indices on the cluster`
`1178`	`1206`	`//`
`1179`	`1207`	`// Use case: You want to restore a particular index or indices onto your cluster with a new name.`

Comments

(0)