bls

Documentation

Index

• Constants
• type BlsClientConfiguration
• type Client
  • func NewClient(ak, sk, endpoint string) (*Client, error)
  • func NewClientWithConfig(config *BlsClientConfiguration) (*Client, error)
  • func (c *Client) CreateFastQuery(args *api.CreateFastQueryBody) error
  • func (c *Client) CreateIndex(logStore string, fulltext bool, fields map[string]api.LogField) error
  • func (c *Client) CreateLogStore(logStore string, retention int) error
  • func (c *Client) DeleteFastQuery(fastQueryName string) error
  • func (c *Client) DeleteIndex(logStore string) error
  • func (c *Client) DeleteLogStore(logStore string) error
  • func (c *Client) DescribeFastQuery(fastQueryName string) (*api.FastQuery, error)
  • func (c *Client) DescribeIndex(logStore string) (*api.IndexFields, error)
  • func (c *Client) DescribeLogStore(logStore string) (*api.LogStore, error)
  • func (c *Client) ListFastQuery(args *api.QueryConditions) (*api.ListFastQueryResult, error)
  • func (c *Client) ListLogStore(args *api.QueryConditions) (*api.ListLogStoreResult, error)
  • func (c *Client) ListLogStream(logStore string, args *api.QueryConditions) (*api.ListLogStreamResult, error)
  • func (c *Client) PullLogRecord(logStore string, args *api.PullLogRecordArgs) (*api.PullLogRecordResult, error)
  • func (c *Client) PushLogRecord(logStore string, logStream string, logType string, logRecords []api.LogRecord) error
  • func (c *Client) QueryLogRecord(logStore string, args *api.QueryLogRecordArgs) (*api.QueryLogResult, error)
  • func (c *Client) UpdateFastQuery(fastQueryName string, args *api.UpdateFastQueryBody) error
  • func (c *Client) UpdateIndex(logStore string, fulltext bool, fields map[string]api.LogField) error
  • func (c *Client) UpdateLogStore(logStore string, retention int) error

Constants

const (
	DEFAULT_SERVICE_DOMAIN = "bls-log.bj.baidubce.com"
)

Types

type BlsClientConfiguration

type BlsClientConfiguration struct {
	Ak       string
	Sk       string
	Endpoint string
}

type Client

type Client struct {
	*bce.BceClient
}

func NewClient

func NewClient(ak, sk, endpoint string) (*Client, error)

func NewClientWithConfig

func NewClientWithConfig(config *BlsClientConfiguration) (*Client, error)

func (*Client) CreateFastQuery

func (c *Client) CreateFastQuery(args *api.CreateFastQueryBody) error

FastQuery opts

func (*Client) CreateIndex

func (c *Client) CreateIndex(logStore string, fulltext bool, fields map[string]api.LogField) error

Index opts

func (*Client) CreateLogStore

func (c *Client) CreateLogStore(logStore string, retention int) error

LogStore opts

func (*Client) DeleteFastQuery

func (c *Client) DeleteFastQuery(fastQueryName string) error

func (*Client) DeleteIndex

func (c *Client) DeleteIndex(logStore string) error

func (*Client) DeleteLogStore

func (c *Client) DeleteLogStore(logStore string) error

func (*Client) DescribeFastQuery

func (c *Client) DescribeFastQuery(fastQueryName string) (*api.FastQuery, error)

func (*Client) DescribeIndex

func (c *Client) DescribeIndex(logStore string) (*api.IndexFields, error)

func (*Client) DescribeLogStore

func (c *Client) DescribeLogStore(logStore string) (*api.LogStore, error)

func (*Client) ListFastQuery

func (c *Client) ListFastQuery(args *api.QueryConditions) (*api.ListFastQueryResult, error)

func (*Client) ListLogStore

func (c *Client) ListLogStore(args *api.QueryConditions) (*api.ListLogStoreResult, error)

func (*Client) ListLogStream

func (c *Client) ListLogStream(logStore string, args *api.QueryConditions) (*api.ListLogStreamResult, error)

LogStream opt

func (*Client) PullLogRecord

func (c *Client) PullLogRecord(logStore string, args *api.PullLogRecordArgs) (*api.PullLogRecordResult, error)

func (*Client) PushLogRecord

func (c *Client) PushLogRecord(logStore string, logStream string, logType string, logRecords []api.LogRecord) error

LogRecord opts

func (*Client) QueryLogRecord

func (c *Client) QueryLogRecord(logStore string, args *api.QueryLogRecordArgs) (*api.QueryLogResult, error)

func (*Client) UpdateFastQuery

func (c *Client) UpdateFastQuery(fastQueryName string, args *api.UpdateFastQueryBody) error

func (*Client) UpdateIndex

func (c *Client) UpdateIndex(logStore string, fulltext bool, fields map[string]api.LogField) error

func (*Client) UpdateLogStore

func (c *Client) UpdateLogStore(logStore string, retention int) error