server

type Client struct {
	ServerAddr string
	Token      string
	Conn       *grpc.ClientConn
	Server     protos.InternalClient
}

type IServerClient interface {
	// GetSetPipelinesCommandByService is called in New() in order to get all AttachCommands in a synchronous manner
	// before we allow the client to start processing.
	GetSetPipelinesCommandByService(ctx context.Context, service string) (*protos.GetSetPipelinesCommandsByServiceResponse, error)

	// GetTailStream returns a gRPC client stream used to send TailResponses to the streamdal server
	GetTailStream(ctx context.Context) (protos.Internal_SendTailClient, error)

	// HeartBeat sends a heartbeat to the streamdal server
	HeartBeat(ctx context.Context, req *protos.HeartbeatRequest) error

	// NewAudience announces a new audience to the streamdal server
	NewAudience(ctx context.Context, aud *protos.Audience, sessionID string) error

	// Notify calls to streamdal server to trigger the configured notification rules for the specified step
	Notify(ctx context.Context, pipeline *protos.Pipeline, step *protos.PipelineStep, aud *protos.Audience) error

	// Reconnect closes any open gRPC connection to the streamdal server and re-establishes a new connection
	// This method won't perform retries as that should be determined by the caller
	Reconnect() error

	// Register registers a new client with the streamdal server.
	// This is ran in a goroutine and constantly listens for commands from the streamdal server
	// such as AttachPipeline, DetachPipeline, etc
	Register(ctx context.Context, req *protos.RegisterRequest) (protos.Internal_RegisterClient, error)

	// SendMetrics ships counter(s) to the server
	SendMetrics(ctx context.Context, counters []*types.CounterEntry) error

	// SendSchema sends a schema to the streamdal server
	SendSchema(ctx context.Context, aud *protos.Audience, jsonSchema []byte) error
}