uranai

README

uranai-kafka

Documentation

Index

• func NewEventHubSaramaConfig(connString string) *sarama.Config
• type Batch
  • func NewBatch(t *FortuneTeller, p Publisher) *Batch
  • func (b *Batch) Run(ctx context.Context) error
• type Client
  • func NewClient(httpClient *http.Client, ...) *Client
  • func (c *Client) Get(ctx context.Context, request *m.CompletionRequest) (*m.CompletionResponse, error)
• type FortuneTeller
  • func NewFortuneTeller(client *Client, temperature float32) *FortuneTeller
  • func (t *FortuneTeller) Listen(ctx context.Context) (*ResultSet, error)
• type Publisher
• type Result
• type ResultSet
• type SaramaPublisher
  • func NewSaramaPublisher(c sarama.SyncProducer, topicName string) *SaramaPublisher
  • func (s SaramaPublisher) Publish(ctx context.Context, resultSet *ResultSet) error

Functions

func NewEventHubSaramaConfig

func NewEventHubSaramaConfig(connString string) *sarama.Config

Types

type Batch

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

func NewBatch

func NewBatch(t *FortuneTeller, p Publisher) *Batch

func (*Batch) Run

func (b *Batch) Run(ctx context.Context) error

type Client

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

func NewClient

func NewClient(httpClient *http.Client, resourceName, deploymentName, apiVersion, accessToken string) *Client

func (*Client) Get

func (c *Client) Get(ctx context.Context, request *m.CompletionRequest) (*m.CompletionResponse, error)

type FortuneTeller

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

func NewFortuneTeller

func NewFortuneTeller(client *Client, temperature float32) *FortuneTeller

func (*FortuneTeller) Listen

func (t *FortuneTeller) Listen(ctx context.Context) (*ResultSet, error)

type Publisher

type Publisher interface {
	Publish(ctx context.Context, resultSet *ResultSet) error
}

type Result

type Result struct {
	Rank         int32     `json:"rank"`
	Name         string    `json:"name"`
	LuckyItem    string    `json:"lucky_item"`
	LuckyColor   string    `json:"lucky_color"`
	LuckyService string    `json:"lucky_service"`
	CareerLuck   int32     `json:"career_luck"`
	LoveLuck     int32     `json:"love_luck"`
	HealthLuck   int32     `json:"health_luck"`
	Description  string    `json:"description"`
	CreatedAt    time.Time `json:"created_at"`
}

type ResultSet

type ResultSet struct {
	Results []Result `json:"results"`
}

type SaramaPublisher

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

func NewSaramaPublisher

func NewSaramaPublisher(c sarama.SyncProducer, topicName string) *SaramaPublisher

func (SaramaPublisher) Publish

func (s SaramaPublisher) Publish(ctx context.Context, resultSet *ResultSet) error