proxy

Documentation

Index

• func WithAddr(addr string) func(proxy *Proxy)
• func WithHttpClient(httpClient *http.Client) func(proxy *Proxy)
• func WithServerUrl(serverUrl string, creds clientcredentials.Config) func(proxy *Proxy)
• type Proxy
  • func New(options ...func(*Proxy)) *Proxy
  • func (s *Proxy) Run() error
  • func (s *Proxy) StreamLogs(ctx context.Context, req *connect.Request[agentv1.StreamLogsRequest]) (*connect.Response[agentv1.StreamLogsResponse], error)
  • func (s *Proxy) UploadLogs(ctx context.Context, req *connect.Request[agentv1.UploadLogsRequest]) (*connect.Response[agentv1.UploadLogsResponse], error)
  • func (s *Proxy) UploadPlan(ctx context.Context, req *connect.Request[agentv1.UploadPlanRequest]) (*connect.Response[agentv1.UploadPlanResponse], error)

Functions

func WithAddr

func WithAddr(addr string) func(proxy *Proxy)

func WithHttpClient

func WithHttpClient(httpClient *http.Client) func(proxy *Proxy)

func WithServerUrl

func WithServerUrl(serverUrl string, creds clientcredentials.Config) func(proxy *Proxy)

Types

type Proxy

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

func New

func New(options ...func(*Proxy)) *Proxy

func (*Proxy) Run

func (s *Proxy) Run() error

func (*Proxy) StreamLogs

func (s *Proxy) StreamLogs(
	ctx context.Context,
	req *connect.Request[agentv1.StreamLogsRequest],
) (*connect.Response[agentv1.StreamLogsResponse], error)

func (*Proxy) UploadLogs

func (s *Proxy) UploadLogs(
	ctx context.Context,
	req *connect.Request[agentv1.UploadLogsRequest],
) (*connect.Response[agentv1.UploadLogsResponse], error)

func (*Proxy) UploadPlan

func (s *Proxy) UploadPlan(
	ctx context.Context,
	req *connect.Request[agentv1.UploadPlanRequest],
) (*connect.Response[agentv1.UploadPlanResponse], error)