client

Documentation

Index

• func HandleResponseCleanup(r *opensearchapi.Response)
• func ParseResponse(osResp *opensearchapi.Response, sink interface{}, okCodes ...int) error
• type APIStatusResponse
  • func (e APIStatusResponse) AppendDiagnostics(d diag.Diagnostics)
  • func (e APIStatusResponse) Error() string
  • func (e APIStatusResponse) HasErrors() bool
  • func (e APIStatusResponse) String() string
• type APIStatusResponseError
  • func (e APIStatusResponseError) Error() string
• type APIStatusResponseErrorRootCause
  • func (e APIStatusResponseErrorRootCause) Error() string
  • func (e APIStatusResponseErrorRootCause) String() string
• type PluginSecurityRole
• type PluginSecurityRoleDelete
  • func (f PluginSecurityRoleDelete) WithContext(v context.Context) func(*PluginSecurityRoleDeleteRequest)
  • func (f PluginSecurityRoleDelete) WithHeader(n map[string]string) func(*PluginSecurityRoleDeleteRequest)
  • func (f PluginSecurityRoleDelete) WithName(v string) func(*PluginSecurityRoleDeleteRequest)
• type PluginSecurityRoleDeleteRequest
  • func (r *PluginSecurityRoleDeleteRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)
• type PluginSecurityRoleIndexPermission
• type PluginSecurityRoleTenantPermission
• type PluginSecurityRoleUpsert
  • func (f PluginSecurityRoleUpsert) WithBody(v io.Reader) func(*PluginSecurityRoleUpsertRequest)
  • func (f PluginSecurityRoleUpsert) WithContext(v context.Context) func(*PluginSecurityRoleUpsertRequest)
  • func (f PluginSecurityRoleUpsert) WithHeader(n map[string]string) func(*PluginSecurityRoleUpsertRequest)
  • func (f PluginSecurityRoleUpsert) WithName(v string) func(request *PluginSecurityRoleUpsertRequest)
• type PluginSecurityRoleUpsertRequest
  • func (r *PluginSecurityRoleUpsertRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)
• type PluginSecurityRolesAPIResponse
• type PluginSecurityRolesGet
  • func (f PluginSecurityRolesGet) WithContext(v context.Context) func(*PluginSecurityRolesGetRequest)
  • func (f PluginSecurityRolesGet) WithHeader(n map[string]string) func(*PluginSecurityRolesGetRequest)
  • func (f PluginSecurityRolesGet) WithName(v string) func(*PluginSecurityRolesGetRequest)
• type PluginSecurityRolesGetRequest
  • func (r PluginSecurityRolesGetRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)
• type TerraformLogger
  • func NewTerraformLogger(provCTX context.Context, requestBodyEnabled, responseBodyEnabled bool) TerraformLogger
  • func (tl TerraformLogger) LogRoundTrip(req *http.Request, resp *http.Response, err error, start time.Time, ...) error
  • func (tl TerraformLogger) RequestBodyEnabled() bool
  • func (tl TerraformLogger) ResponseBodyEnabled() bool

Functions

func HandleResponseCleanup

func HandleResponseCleanup(r *opensearchapi.Response)

func ParseResponse

func ParseResponse(osResp *opensearchapi.Response, sink interface{}, okCodes ...int) error

Types

type APIStatusResponse

type APIStatusResponse struct {
	Status   string                  `json:"status"`
	Message  string                  `json:"message"`
	APIError *APIStatusResponseError `json:"error"`

	WarningsHeader []string `json:"-"`
}

func (APIStatusResponse) AppendDiagnostics

func (e APIStatusResponse) AppendDiagnostics(d diag.Diagnostics)

func (APIStatusResponse) Error

func (e APIStatusResponse) Error() string

func (APIStatusResponse) HasErrors

func (e APIStatusResponse) HasErrors() bool

func (APIStatusResponse) String

func (e APIStatusResponse) String() string

type APIStatusResponseError

type APIStatusResponseError struct {
	RootCause []APIStatusResponseErrorRootCause `json:"root_cause"`
}

func (APIStatusResponseError) Error

func (e APIStatusResponseError) Error() string

type APIStatusResponseErrorRootCause

type APIStatusResponseErrorRootCause struct {
	Type   string `json:"type"`
	Reason string `json:"reason"`
}

func (APIStatusResponseErrorRootCause) Error

func (e APIStatusResponseErrorRootCause) Error() string

func (APIStatusResponseErrorRootCause) String

func (e APIStatusResponseErrorRootCause) String() string

type PluginSecurityRole

type PluginSecurityRole struct {
	RoleName string `json:"-" tfsdk:"-"`

	Description string `json:"description" tfsdk:"description"`

	ClusterPermissions []string                             `json:"cluster_permissions" tfsdk:"cluster_permissions"`
	IndexPermissions   []PluginSecurityRoleIndexPermission  `json:"index_permissions" tfsdk:"index_permissions"`
	TenantPermissions  []PluginSecurityRoleTenantPermission `json:"tenant_permissions" tfsdk:"tenant_permissions"`

	Reserved *bool `json:"reserved,omitempty" tfsdk:"reserved"`
	Hidden   *bool `json:"hidden,omitempty" tfsdk:"hidden"`
	Static   *bool `json:"static,omitempty" tfsdk:"static"`
}

type PluginSecurityRoleDelete

type PluginSecurityRoleDelete func(o ...func(*PluginSecurityRoleDeleteRequest)) (*opensearchapi.Response, error)

func (PluginSecurityRoleDelete) WithContext

func (f PluginSecurityRoleDelete) WithContext(v context.Context) func(*PluginSecurityRoleDeleteRequest)

func (PluginSecurityRoleDelete) WithHeader

func (f PluginSecurityRoleDelete) WithHeader(n map[string]string) func(*PluginSecurityRoleDeleteRequest)

func (PluginSecurityRoleDelete) WithName

func (f PluginSecurityRoleDelete) WithName(v string) func(*PluginSecurityRoleDeleteRequest)

type PluginSecurityRoleDeleteRequest

type PluginSecurityRoleDeleteRequest struct {
	Name string

	Header http.Header
	// contains filtered or unexported fields
}

func (*PluginSecurityRoleDeleteRequest) Do

func (r *PluginSecurityRoleDeleteRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)

type PluginSecurityRoleIndexPermission

type PluginSecurityRoleIndexPermission struct {
	IndexPatterns  []string `json:"index_patterns" tfsdk:"index_patterns"`
	DLS            string   `json:"dls" tfsdk:"dls"`
	FLS            string   `json:"fls" tfsdk:"fls"`
	MaskedFields   []string `json:"masked_fields" tfsdk:"masked_fields"`
	AllowedActions []string `json:"allowed_actions" tfsdk:"allowed_actions"`
}

type PluginSecurityRoleTenantPermission

type PluginSecurityRoleTenantPermission struct {
	TenantPatterns []string `json:"tenant_patterns" tfsdk:"tenant_patterns"`
	AllowedActions []string `json:"allowed_actions" tfsdk:"allowed_actions"`
}

type PluginSecurityRoleUpsert

type PluginSecurityRoleUpsert func(o ...func(request *PluginSecurityRoleUpsertRequest)) (*opensearchapi.Response, error)

func (PluginSecurityRoleUpsert) WithBody

func (f PluginSecurityRoleUpsert) WithBody(v io.Reader) func(*PluginSecurityRoleUpsertRequest)

func (PluginSecurityRoleUpsert) WithContext

func (f PluginSecurityRoleUpsert) WithContext(v context.Context) func(*PluginSecurityRoleUpsertRequest)

func (PluginSecurityRoleUpsert) WithHeader

func (f PluginSecurityRoleUpsert) WithHeader(n map[string]string) func(*PluginSecurityRoleUpsertRequest)

func (PluginSecurityRoleUpsert) WithName

func (f PluginSecurityRoleUpsert) WithName(v string) func(request *PluginSecurityRoleUpsertRequest)

type PluginSecurityRoleUpsertRequest

type PluginSecurityRoleUpsertRequest struct {
	Name string

	Body io.Reader

	Header http.Header
	// contains filtered or unexported fields
}

func (*PluginSecurityRoleUpsertRequest) Do

func (r *PluginSecurityRoleUpsertRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)

type PluginSecurityRolesAPIResponse

type PluginSecurityRolesAPIResponse map[string]PluginSecurityRole

type PluginSecurityRolesGet

type PluginSecurityRolesGet func(o ...func(*PluginSecurityRolesGetRequest)) (*opensearchapi.Response, error)

func (PluginSecurityRolesGet) WithContext

func (f PluginSecurityRolesGet) WithContext(v context.Context) func(*PluginSecurityRolesGetRequest)

func (PluginSecurityRolesGet) WithHeader

func (f PluginSecurityRolesGet) WithHeader(n map[string]string) func(*PluginSecurityRolesGetRequest)

func (PluginSecurityRolesGet) WithName

func (f PluginSecurityRolesGet) WithName(v string) func(*PluginSecurityRolesGetRequest)

type PluginSecurityRolesGetRequest

type PluginSecurityRolesGetRequest struct {
	Name string

	Header http.Header
	// contains filtered or unexported fields
}

func (PluginSecurityRolesGetRequest) Do

func (r PluginSecurityRolesGetRequest) Do(ctx context.Context, transport opensearchapi.Transport) (*opensearchapi.Response, error)

type TerraformLogger

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

func NewTerraformLogger

func NewTerraformLogger(provCTX context.Context, requestBodyEnabled, responseBodyEnabled bool) TerraformLogger

func (TerraformLogger) LogRoundTrip

func (tl TerraformLogger) LogRoundTrip(req *http.Request, resp *http.Response, err error, start time.Time, dur time.Duration) error

func (TerraformLogger) RequestBodyEnabled

func (tl TerraformLogger) RequestBodyEnabled() bool

func (TerraformLogger) ResponseBodyEnabled

func (tl TerraformLogger) ResponseBodyEnabled() bool