ots

Documentation

Index

• Constants
• type Client
  • func NewClient() (client *Client, err error)
  • func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)
  • func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)
  • func (client *Client) CreateTrigger(request *CreateTriggerRequest) (response *CreateTriggerResponse, err error)
  • func (client *Client) CreateTriggerWithCallback(request *CreateTriggerRequest, ...) <-chan int
  • func (client *Client) CreateTriggerWithChan(request *CreateTriggerRequest) (<-chan *CreateTriggerResponse, <-chan error)
  • func (client *Client) DeleteTrigger(request *DeleteTriggerRequest) (response *DeleteTriggerResponse, err error)
  • func (client *Client) DeleteTriggerWithCallback(request *DeleteTriggerRequest, ...) <-chan int
  • func (client *Client) DeleteTriggerWithChan(request *DeleteTriggerRequest) (<-chan *DeleteTriggerResponse, <-chan error)
  • func (client *Client) GetTrigger(request *GetTriggerRequest) (response *GetTriggerResponse, err error)
  • func (client *Client) GetTriggerWithCallback(request *GetTriggerRequest, ...) <-chan int
  • func (client *Client) GetTriggerWithChan(request *GetTriggerRequest) (<-chan *GetTriggerResponse, <-chan error)
  • func (client *Client) ListTrigger(request *ListTriggerRequest) (response *ListTriggerResponse, err error)
  • func (client *Client) ListTriggerWithCallback(request *ListTriggerRequest, ...) <-chan int
  • func (client *Client) ListTriggerWithChan(request *ListTriggerRequest) (<-chan *ListTriggerResponse, <-chan error)
• type CreateTriggerRequest
  • func NewCreateTriggerRequest(domain, instance, table string, body *CreateTriggerRequestBody) (request *CreateTriggerRequest, err error)
• type CreateTriggerRequestBody
• type CreateTriggerResponse
  • func CreateCreateTriggerResponse() (response *CreateTriggerResponse)
  • func (resp *CreateTriggerResponse) GetBody() (body *CreateTriggerResponseBody, err error)
• type CreateTriggerResponseBody
• type DeleteTriggerRequest
  • func NewDeleteTriggerRequest(domain, instance, table, trigger string) (request *DeleteTriggerRequest)
• type DeleteTriggerResponse
  • func CreateDeleteTriggerResponse() (response *DeleteTriggerResponse)
• type GetTriggerRequest
  • func NewGetTriggerRequest(domain, instance, table, trigger string) (request *GetTriggerRequest)
• type GetTriggerResponse
  • func CreateGetTriggerResponse() (response *GetTriggerResponse)
  • func (resp *GetTriggerResponse) GetBody() (body *GetTriggerResponseBody, err error)
• type GetTriggerResponseBody
• type ListTriggerRequest
  • func NewListTriggerRequest(domain, instance, table string) (request *ListTriggerRequest)
• type ListTriggerResponse
  • func CreateListTriggerResponse() (response *ListTriggerResponse)
  • func (resp *ListTriggerResponse) GetBody() (body *ListTriggerResponseBody, err error)
• type ListTriggerResponseBody
• type TriggerInfo
• type TriggerResponseBase
• type UdfInfo

Constants

const (
	CanNotMarshalRequestBodyCode    = "SDK.CanNotMarshalRequestBody"
	CanNotMarshalRequestBodyMessage = "Can not marshal body(param = %v)"

	CanNotUnmarshalRequestBodyCode    = "SDK.CanNotUnmarshalRequestBody"
	CanNotUnmarshalRequestBodyMessage = "Can not unmarshal body(param = %s)"
)

const ApiVersion = "v1"

Types

type Client

type Client struct {
	sdk.Client
}

func NewClient

func NewClient() (client *Client, err error)

func NewClientWithAccessKey

func NewClientWithAccessKey(regionId, accessKeyId, accessKeySecret string) (client *Client, err error)

func NewClientWithOptions

func NewClientWithOptions(regionId string, config *sdk.Config, credential auth.Credential) (client *Client, err error)

func (*Client) CreateTrigger

func (client *Client) CreateTrigger(request *CreateTriggerRequest) (response *CreateTriggerResponse, err error)

func (*Client) CreateTriggerWithCallback

func (client *Client) CreateTriggerWithCallback(request *CreateTriggerRequest, callback func(response *CreateTriggerResponse, err error)) <-chan int

func (*Client) CreateTriggerWithChan

func (client *Client) CreateTriggerWithChan(request *CreateTriggerRequest) (<-chan *CreateTriggerResponse, <-chan error)

func (*Client) DeleteTrigger

func (client *Client) DeleteTrigger(request *DeleteTriggerRequest) (response *DeleteTriggerResponse, err error)

func (*Client) DeleteTriggerWithCallback

func (client *Client) DeleteTriggerWithCallback(request *DeleteTriggerRequest, callback func(response *DeleteTriggerResponse, err error)) <-chan int

func (*Client) DeleteTriggerWithChan

func (client *Client) DeleteTriggerWithChan(request *DeleteTriggerRequest) (<-chan *DeleteTriggerResponse, <-chan error)

func (*Client) GetTrigger

func (client *Client) GetTrigger(request *GetTriggerRequest) (response *GetTriggerResponse, err error)

func (*Client) GetTriggerWithCallback

func (client *Client) GetTriggerWithCallback(request *GetTriggerRequest, callback func(response *GetTriggerResponse, err error)) <-chan int

func (*Client) GetTriggerWithChan

func (client *Client) GetTriggerWithChan(request *GetTriggerRequest) (<-chan *GetTriggerResponse, <-chan error)

func (*Client) ListTrigger

func (client *Client) ListTrigger(request *ListTriggerRequest) (response *ListTriggerResponse, err error)

func (*Client) ListTriggerWithCallback

func (client *Client) ListTriggerWithCallback(request *ListTriggerRequest, callback func(response *ListTriggerResponse, err error)) <-chan int

func (*Client) ListTriggerWithChan

func (client *Client) ListTriggerWithChan(request *ListTriggerRequest) (<-chan *ListTriggerResponse, <-chan error)

type CreateTriggerRequest

type CreateTriggerRequest struct {
	*requests.RoaRequest
	InstanceName string `position:"Path" name:"InstanceName"`
	ApiVersion   string `position:"Path" name:"ApiVersion"`
	TableName    string `position:"Path" name:"TableName"`
}

func NewCreateTriggerRequest

func NewCreateTriggerRequest(domain, instance, table string, body *CreateTriggerRequestBody) (request *CreateTriggerRequest, err error)

type CreateTriggerRequestBody

type CreateTriggerRequestBody struct {
	RoleArn     string
	TriggerName string
	UdfInfo     *UdfInfo
}

type CreateTriggerResponse

type CreateTriggerResponse struct {
	*responses.BaseResponse
}

func CreateCreateTriggerResponse

func CreateCreateTriggerResponse() (response *CreateTriggerResponse)

func (*CreateTriggerResponse) GetBody

func (resp *CreateTriggerResponse) GetBody() (body *CreateTriggerResponseBody, err error)

type CreateTriggerResponseBody

type CreateTriggerResponseBody struct {
	TriggerResponseBase
	Etag string
}

type DeleteTriggerRequest

type DeleteTriggerRequest struct {
	*requests.RoaRequest
	InstanceName string `position:"Path" name:"InstanceName"`
	TriggerName  string `position:"Path" name:"TriggerName"`
	ApiVersion   string `position:"Path" name:"ApiVersion"`
	TableName    string `position:"Path" name:"TableName"`
}

func NewDeleteTriggerRequest

func NewDeleteTriggerRequest(domain, instance, table, trigger string) (request *DeleteTriggerRequest)

type DeleteTriggerResponse

type DeleteTriggerResponse struct {
	*responses.BaseResponse
}

func CreateDeleteTriggerResponse

func CreateDeleteTriggerResponse() (response *DeleteTriggerResponse)

type GetTriggerRequest

type GetTriggerRequest struct {
	*requests.RoaRequest
	InstanceName string `position:"Path" name:"InstanceName"`
	TriggerName  string `position:"Path" name:"TriggerName"`
	ApiVersion   string `position:"Path" name:"ApiVersion"`
	TableName    string `position:"Path" name:"TableName"`
}

func NewGetTriggerRequest

func NewGetTriggerRequest(domain, instance, table, trigger string) (request *GetTriggerRequest)

type GetTriggerResponse

type GetTriggerResponse struct {
	*responses.BaseResponse
}

func CreateGetTriggerResponse

func CreateGetTriggerResponse() (response *GetTriggerResponse)

func (*GetTriggerResponse) GetBody

func (resp *GetTriggerResponse) GetBody() (body *GetTriggerResponseBody, err error)

type GetTriggerResponseBody

type GetTriggerResponseBody struct {
	TriggerResponseBase
	Trigger *TriggerInfo
}

type ListTriggerRequest

type ListTriggerRequest struct {
	*requests.RoaRequest
	InstanceName string `position:"Path" name:"InstanceName"`
	ApiVersion   string `position:"Path" name:"ApiVersion"`
	TableName    string `position:"Path" name:"TableName"`
}

func NewListTriggerRequest

func NewListTriggerRequest(domain, instance, table string) (request *ListTriggerRequest)

type ListTriggerResponse

type ListTriggerResponse struct {
	*responses.BaseResponse
}

func CreateListTriggerResponse

func CreateListTriggerResponse() (response *ListTriggerResponse)

func (*ListTriggerResponse) GetBody

func (resp *ListTriggerResponse) GetBody() (body *ListTriggerResponseBody, err error)

type ListTriggerResponseBody

type ListTriggerResponseBody struct {
	TriggerResponseBase
	Triggers []*TriggerInfo
}

type TriggerInfo

type TriggerInfo struct {
	TriggerName  string
	AssumeRole   string
	CreateTime   int64
	InstanceName string
	DataTable    string
	UdfInfo      *UdfInfo
	Etag         string
	TimerId      string
}

type TriggerResponseBase

type TriggerResponseBase struct {
	Code    string
	Message string
}

type UdfInfo

type UdfInfo struct {
	ServiceName  string
	FunctionName string
}