common

Documentation

Index

• Constants
• Variables
• type JavaConfig
• type JvmLogRecord
  • func (r *JvmLogRecord) ToEntry() log.Entry
• type Service
  • func New(scaffoldFiles *zip.Reader) *Service
  • func (s *Service) Build(ctx context.Context, req *connect.Request[langpb.BuildRequest], ...) error
  • func (s *Service) BuildContextUpdated(ctx context.Context, req *connect.Request[langpb.BuildContextUpdatedRequest]) (*connect.Response[langpb.BuildContextUpdatedResponse], error)
  • func (s *Service) CreateModule(ctx context.Context, req *connect.Request[langpb.CreateModuleRequest]) (*connect.Response[langpb.CreateModuleResponse], error)
  • func (s *Service) GenerateStubs(ctx context.Context, req *connect.Request[langpb.GenerateStubsRequest]) (*connect.Response[langpb.GenerateStubsResponse], error)
  • func (s *Service) GetCreateModuleFlags(ctx context.Context, req *connect.Request[langpb.GetCreateModuleFlagsRequest]) (*connect.Response[langpb.GetCreateModuleFlagsResponse], error)
  • func (s *Service) GetDependencies(ctx context.Context, req *connect.Request[langpb.GetDependenciesRequest]) (*connect.Response[langpb.GetDependenciesResponse], error)
  • func (s *Service) ModuleConfigDefaults(ctx context.Context, req *connect.Request[langpb.ModuleConfigDefaultsRequest]) (*connect.Response[langpb.ModuleConfigDefaultsResponse], error)
  • func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)
  • func (s *Service) SyncStubReferences(ctx context.Context, req *connect.Request[langpb.SyncStubReferencesRequest]) (*connect.Response[langpb.SyncStubReferencesResponse], error)

Constants

const BuildLockTimeout = time.Minute

const ErrorFile = "errors.pb"

const JavaBuildToolGradle string = "gradle"

const JavaBuildToolMaven string = "maven"

const SchemaFile = "schema.pb"

Variables

var ErrInvalidateDependencies = errors.New("dependencies need to be updated")

Types

type JavaConfig

type JavaConfig struct {
	BuildTool string `mapstructure:"build-tool"`
}

type JvmLogRecord

type JvmLogRecord struct {
	Timestamp       time.Time `json:"timestamp"`
	Sequence        int       `json:"sequence"`
	LoggerClassName string    `json:"loggerClassName"`
	LoggerName      string    `json:"loggerName"`
	Level           string    `json:"level"`
	Message         string    `json:"message"`
	ThreadName      string    `json:"threadName"`
	ThreadID        int       `json:"threadId"`
	Mdc             any       `json:"mdc"`
	Ndc             string    `json:"ndc"`
	HostName        string    `json:"hostName"`
	ProcessName     string    `json:"processName"`
	ProcessID       int       `json:"processId"`
}

func (*JvmLogRecord) ToEntry

func (r *JvmLogRecord) ToEntry() log.Entry

type Service

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

func New

func New(scaffoldFiles *zip.Reader) *Service

func (*Service) Build

func (s *Service) Build(ctx context.Context, req *connect.Request[langpb.BuildRequest], stream *connect.ServerStream[langpb.BuildResponse]) error

Build the module and stream back build events.

A BuildSuccess or BuildFailure event must be streamed back with the request's context id to indicate the end of the build.

The request can include the option to "rebuild_automatically". In this case the plugin should watch for file changes and automatically rebuild as needed as long as this build request is alive. Each automactic rebuild must include the latest build context id provided by the request or subsequent BuildContextUpdated calls.

func (*Service) BuildContextUpdated

func (s *Service) BuildContextUpdated(ctx context.Context, req *connect.Request[langpb.BuildContextUpdatedRequest]) (*connect.Response[langpb.BuildContextUpdatedResponse], error)

BuildContextUpdated is called whenever the build context is update while a Build call with "rebuild_automatically" is active.

Each time this call is made, the Build call must send back a corresponding BuildSuccess or BuildFailure event with the updated build context id with "is_automatic_rebuild" as false.

func (*Service) CreateModule

func (s *Service) CreateModule(ctx context.Context, req *connect.Request[langpb.CreateModuleRequest]) (*connect.Response[langpb.CreateModuleResponse], error)

CreateModule generates files for a new module with the requested name

func (*Service) GenerateStubs

func (s *Service) GenerateStubs(ctx context.Context, req *connect.Request[langpb.GenerateStubsRequest]) (*connect.Response[langpb.GenerateStubsResponse], error)

func (*Service) GetCreateModuleFlags

func (s *Service) GetCreateModuleFlags(ctx context.Context, req *connect.Request[langpb.GetCreateModuleFlagsRequest]) (*connect.Response[langpb.GetCreateModuleFlagsResponse], error)

func (*Service) GetDependencies

func (s *Service) GetDependencies(ctx context.Context, req *connect.Request[langpb.GetDependenciesRequest]) (*connect.Response[langpb.GetDependenciesResponse], error)

func (*Service) ModuleConfigDefaults

func (s *Service) ModuleConfigDefaults(ctx context.Context, req *connect.Request[langpb.ModuleConfigDefaultsRequest]) (*connect.Response[langpb.ModuleConfigDefaultsResponse], error)

func (*Service) Ping

func (s *Service) Ping(ctx context.Context, req *connect.Request[ftlv1.PingRequest]) (*connect.Response[ftlv1.PingResponse], error)

func (*Service) SyncStubReferences

func (s *Service) SyncStubReferences(ctx context.Context, req *connect.Request[langpb.SyncStubReferencesRequest]) (*connect.Response[langpb.SyncStubReferencesResponse], error)